Skip to content

Commit 9bf9a65

Browse files
author
dapeng
committed
1 parent 6943b54 commit 9bf9a65

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

core/src/main/java/com/dtstack/flink/sql/util/FieldReplaceUtil.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -253,6 +253,7 @@ public static SqlNode replaceSelectFieldName(SqlNode selectNode,
253253
|| selectNode.getKind() == TIMESTAMP_ADD
254254
|| selectNode.getKind() == TIMESTAMP_DIFF
255255
|| selectNode.getKind() == LIKE
256+
|| selectNode.getKind() == COALESCE
256257

257258
){
258259
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;

0 commit comments

Comments
 (0)