Skip to content

Commit e3be129

Browse files
committed
[FLINK-38532] Parse plural time unit in test
1 parent 3b35f2f commit e3be129

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/MaterializedTableStatementParserTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -392,7 +392,7 @@ private static Map.Entry<String, String> fullExample() {
392392
+ " 'group.id' = 'latest', \n"
393393
+ " 'kafka.topic' = 'log.test'\n"
394394
+ ")\n"
395-
+ "FRESHNESS = INTERVAL '3' MINUTE\n"
395+
+ "FRESHNESS = INTERVAL '3' MINUTES\n"
396396
+ "AS SELECT a, b, h, t m FROM source",
397397
"CREATE MATERIALIZED TABLE `TBL1`\n"
398398
+ "(\n"
@@ -437,7 +437,7 @@ private static Map.Entry<String, String> withoutTableConstraint() {
437437
return new AbstractMap.SimpleEntry<>(
438438
"CREATE MATERIALIZED TABLE tbl1\n"
439439
+ "COMMENT 'table comment'\n"
440-
+ "FRESHNESS = INTERVAL '3' DAY\n"
440+
+ "FRESHNESS = INTERVAL '3' DAYS\n"
441441
+ "REFRESH_MODE = FULL\n"
442442
+ "AS SELECT a, b, h, t m FROM source",
443443
"CREATE MATERIALIZED TABLE `TBL1`\n"

0 commit comments

Comments
 (0)