Skip to content

Commit bb8e5ef

Browse files
committed
[FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled
1 parent 95a193f commit bb8e5ef

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlMaterializedTableNodeToOperationConverterTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -143,6 +143,7 @@ void before() throws TableAlreadyExistException, DatabaseNotExistException {
143143
+ " WATERMARK FOR t as current_timestamp - INTERVAL '5' SECOND"
144144
+ ")\n"
145145
+ "COMMENT 'materialized table comment'\n"
146+
+ "DISTRIBUTED BY HASH (b) INTO 7 BUCKETS\n"
146147
+ "WITH (\n"
147148
+ " 'connector' = 'filesystem', \n"
148149
+ " 'format' = 'json'\n"
@@ -731,7 +732,6 @@ void testCreateOrAlterMaterializedTableForExistingTable() throws TableNotExistEx
731732
+ " CONSTRAINT ct1 PRIMARY KEY(a) NOT ENFORCED"
732733
+ ")\n"
733734
+ "COMMENT 'materialized table comment'\n"
734-
+ "DISTRIBUTED BY HASH (b) INTO 7 BUCKETS\n"
735735
+ "PARTITIONED BY (a, d)\n"
736736
+ "WITH (\n"
737737
+ " 'format' = 'json2'\n"

0 commit comments

Comments
 (0)