Skip to content

Commit 481c4f0

Browse files
修竹修竹
authored andcommitted
解决sql where条件中有like启动异常问题
1 parent 80f3437 commit 481c4f0

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -522,6 +522,7 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
522522
|| selectNode.getKind() == CONTAINS
523523
|| selectNode.getKind() == TIMESTAMP_ADD
524524
|| selectNode.getKind() == TIMESTAMP_DIFF
525+
|| selectNode.getKind() == LIKE
525526

526527
){
527528
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;

0 commit comments

Comments
 (0)