Skip to content

Commit 188d42d

Browse files
authored
fix(flink): fix flinksql syntax error about ROW and function using (#383)
Co-authored-by: zhaoge <>
1 parent 64ed7e4 commit 188d42d

File tree

6 files changed

+2296
-2122
lines changed

6 files changed

+2296
-2122
lines changed

src/grammar/flink/FlinkSqlParser.g4

+3-2
Original file line numberDiff line numberDiff line change
@@ -241,6 +241,7 @@ mapTypeDimension
241241

242242
rowTypeDimension
243243
: LESS_SYMBOL columnName columnType (COMMA columnName columnType)* GREATER_SYMBOL
244+
| LR_BRACKET columnName columnType (COMMA columnName columnType)* RR_BRACKET
244245
;
245246

246247
columnConstraint
@@ -647,7 +648,7 @@ limitClause
647648
;
648649

649650
partitionByClause
650-
: KW_PARTITION KW_BY columnName (COMMA columnName)*
651+
: KW_PARTITION KW_BY (columnName | primaryExpression) (COMMA (columnName | primaryExpression))*
651652
;
652653

653654
quantifiers
@@ -1216,4 +1217,4 @@ nonReservedKeywords
12161217
| KW_WEEK
12171218
| KW_YEARS
12181219
| KW_ZONE
1219-
;
1220+
;

src/lib/flink/FlinkSqlParser.interp

+1-1
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)