Skip to content

Commit 61c9e6a

Browse files
committed
Merge branch '1.8._3.9.1_timestamo' into '1.8_v3.9.1'
支持timestamp_add See merge request !133
2 parents 0607095 + 1614b87 commit 61c9e6a

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -520,6 +520,8 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
520520
|| selectNode.getKind() == IS_NULL
521521
|| selectNode.getKind() == IS_NOT_NULL
522522
|| selectNode.getKind() == CONTAINS
523+
|| selectNode.getKind() == TIMESTAMP_ADD
524+
|| selectNode.getKind() == TIMESTAMP_DIFF
523525

524526
){
525527
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,8 @@ public static SqlNode replaceSelectFieldTabName(SqlNode selectNode, Map<String,S
159159
|| selectNode.getKind() == IS_NULL
160160
|| selectNode.getKind() == IS_NOT_NULL
161161
|| selectNode.getKind() == CONTAINS
162+
|| selectNode.getKind() == TIMESTAMP_ADD
163+
|| selectNode.getKind() == TIMESTAMP_DIFF
162164

163165
){
164166
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;

0 commit comments

Comments
 (0)