Skip to content

Commit 3c28f19

Browse files
author
gituser
committed
Merge branch 'hotfix_1.10_4.0.x_30448' into 1.10_release_4.0.x
2 parents edd503a + ee8a25b commit 3c28f19

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

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

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -229,6 +229,13 @@ public static String dealSelectResultWithJoinInfo(JoinInfo joinInfo, SqlSelect s
229229
queueInfo.offer(joinInfo.getLeftNode());
230230
}
231231

232+
if(joinInfo.getLeftNode().getKind() == AS){
233+
SqlNode leftSqlNode = ((SqlBasicCall)joinInfo.getLeftNode()).getOperands()[0];
234+
if (leftSqlNode.getKind() == UNION){
235+
queueInfo.offer(joinInfo.getLeftNode());
236+
}
237+
}
238+
232239
queueInfo.offer(joinInfo);
233240
} else {
234241
//Determining right is not a simple table

0 commit comments

Comments
 (0)