Skip to content

Commit c5fbef2

Browse files
committed
[FLINK-38355] Add test for expanded query in SHOW CREATE MATERIALIZED TABLE
1 parent d600988 commit c5fbef2

File tree

1 file changed

+24
-2
lines changed

1 file changed

+24
-2
lines changed

flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/internal/ShowCreateUtilTest.java

Lines changed: 24 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,7 @@ private static Collection<Arguments> argsForShowCreateMaterializedTable() {
325325
IntervalFreshness.ofMinute("3"),
326326
RefreshMode.FULL,
327327
"SELECT id, name FROM tbl_a",
328-
"SELECT id, name FROM tbl_a"),
328+
"SELECT id, name FROM `catalogName`.`dbName`.`tbl_a`"),
329329
"CREATE MATERIALIZED TABLE `catalogName`.`dbName`.`materializedTableName` (\n"
330330
+ " `id` INT,\n"
331331
+ " `name` VARCHAR(2147483647)\n"
@@ -335,7 +335,29 @@ private static Collection<Arguments> argsForShowCreateMaterializedTable() {
335335
+ "PARTITIONED BY (`id`)\n"
336336
+ "FRESHNESS = INTERVAL '3' MINUTE\n"
337337
+ "REFRESH_MODE = FULL\n"
338-
+ "AS SELECT id, name FROM tbl_a\n"));
338+
+ "AS SELECT id, name FROM `catalogName`.`dbName`.`tbl_a`\n"));
339+
340+
argList.add(
341+
Arguments.of(
342+
createResolvedMaterialized(
343+
TWO_COLUMNS_SCHEMA,
344+
"Materialized table comment",
345+
List.of("id"),
346+
TableDistribution.of(TableDistribution.Kind.HASH, 5, List.of("id")),
347+
IntervalFreshness.ofMinute("3"),
348+
RefreshMode.FULL,
349+
"SELECT * FROM tbl_a",
350+
"SELECT id, name FROM `catalogName`.`dbName`.`tbl_a`"),
351+
"CREATE MATERIALIZED TABLE `catalogName`.`dbName`.`materializedTableName` (\n"
352+
+ " `id` INT,\n"
353+
+ " `name` VARCHAR(2147483647)\n"
354+
+ ")\n"
355+
+ "COMMENT 'Materialized table comment'\n"
356+
+ "DISTRIBUTED BY HASH(`id`) INTO 5 BUCKETS\n"
357+
+ "PARTITIONED BY (`id`)\n"
358+
+ "FRESHNESS = INTERVAL '3' MINUTE\n"
359+
+ "REFRESH_MODE = FULL\n"
360+
+ "AS SELECT id, name FROM `catalogName`.`dbName`.`tbl_a`\n"));
339361

340362
return argList;
341363
}

0 commit comments

Comments
 (0)