Skip to content

Commit dccadf1

Browse files
author
zhaoge
committed
fix(flink): #442 fix flink's insert values() can't support function problem
1 parent 3684ae7 commit dccadf1

File tree

6 files changed

+2825
-2724
lines changed

6 files changed

+2825
-2724
lines changed

src/grammar/flink/FlinkSqlParser.g4

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -439,7 +439,12 @@ valuesDefinition
439439
;
440440

441441
valuesRowDefinition
442-
: LR_BRACKET constant (COMMA constant)* RR_BRACKET
442+
: LR_BRACKET valueDefinition (COMMA valueDefinition)* RR_BRACKET
443+
;
444+
445+
valueDefinition
446+
: constant
447+
| functionCallExpression
443448
;
444449

445450
insertMulStatementCompatibility

src/lib/flink/FlinkSqlParser.interp

Lines changed: 2 additions & 1 deletion
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)