diff --git a/src/frontend/src/handler/describe.rs b/src/frontend/src/handler/describe.rs index 25c705f5a1e3e..4100b9a20be02 100644 --- a/src/frontend/src/handler/describe.rs +++ b/src/frontend/src/handler/describe.rs @@ -231,6 +231,7 @@ mod tests { "v3".into() => "integer".into(), "v4".into() => "integer".into(), "primary key".into() => "v3".into(), + "distribution key".into() => "v3".into(), "idx1".into() => "index(v1 DESC, v2 ASC, v3 ASC) include(v4) distributed by(v1)".into(), }; diff --git a/src/frontend/src/handler/show.rs b/src/frontend/src/handler/show.rs index 4c5faf576a890..15b423e259299 100644 --- a/src/frontend/src/handler/show.rs +++ b/src/frontend/src/handler/show.rs @@ -584,6 +584,8 @@ mod tests { "country.city.zipcode".into() => "character varying".into(), "rate".into() => "real".into(), "country".into() => "test.Country".into(), + "_rw_kafka_timestamp".into() => "timestamp with time zone".into(), + "_row_id".into() => "serial".into(), }; assert_eq!(columns, expected_columns);