Skip to content

Commit ce71b01

Browse files
committed
fix 不带where 条件下的空指针问题
1 parent 3a7659d commit ce71b01

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -353,6 +353,11 @@ private Tuple2<Boolean, SqlBasicCall> dealNestJoin(SqlJoin joinNode, Set<String>
353353
}
354354

355355
public boolean checkAndRemoveCondition(Set<String> fromTableNameSet, SqlBasicCall parentWhere, List<SqlBasicCall> extractContition){
356+
357+
if(parentWhere == null){
358+
return false;
359+
}
360+
356361
SqlKind kind = parentWhere.getKind();
357362
if(kind == AND){
358363
boolean removeLeft = checkAndRemoveCondition(fromTableNameSet, (SqlBasicCall) parentWhere.getOperands()[0], extractContition);

0 commit comments

Comments
 (0)