Skip to content

Commit 66d0e34

Browse files
committed
fix ES6 not support constant join
1 parent 3613a79 commit 66d0e34

File tree

1 file changed

+11
-1
lines changed

1 file changed

+11
-1
lines changed

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

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,17 @@ public static void parseAnd(SqlNode conditionNode, List<SqlNode> sqlNodeList) {
7474

7575
public static void parseJoinCompareOperate(SqlNode condition, List<String> sqlJoinCompareOperate) {
7676
SqlBasicCall joinCondition = (SqlBasicCall) condition;
77-
if (joinCondition.getKind() == SqlKind.AND) {
77+
78+
// 跳过常量JOIN的等式
79+
if (joinCondition.getKind() == SqlKind.EQUALS) {
80+
SqlNode left = joinCondition.getOperands()[0];
81+
SqlNode right = joinCondition.getOperands()[1];
82+
if (left.getKind() != SqlKind.LITERAL &&
83+
right.getKind() != SqlKind.LITERAL) {
84+
String operator = transformNotEqualsOperator(joinCondition.getKind());
85+
sqlJoinCompareOperate.add(operator);
86+
}
87+
} else if (joinCondition.getKind() == SqlKind.AND) {
7888
List<SqlNode> operandList = joinCondition.getOperandList();
7989
for (SqlNode sqlNode : operandList) {
8090
parseJoinCompareOperate(sqlNode, sqlJoinCompareOperate);

0 commit comments

Comments
 (0)