Merge branch '1.5_v3.5.5_noas' into '1.5_v3.5.5'

join 没有as 表名 的时候报错



See merge request !25

Author: toutian

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

@@ -159,8 +159,16 @@ private JoinInfo dealJoinNode(SqlJoin joinNode, Set<String> sideTableSet, Queue<
         JoinInfo tableInfo = new JoinInfo();
         tableInfo.setLeftTableName(leftTbName);
         tableInfo.setRightTableName(rightTableName);
-        tableInfo.setLeftTableAlias(leftTbAlias);
-        tableInfo.setRightTableAlias(rightTableAlias);
+        if (leftTbAlias.equals("")){
+            tableInfo.setLeftTableAlias(leftTbName);
+        } else {
+            tableInfo.setLeftTableAlias(leftTbAlias);
+        }
+        if (leftTbAlias.equals("")){
+            tableInfo.setRightTableAlias(rightTableName);
+        } else {
+            tableInfo.setRightTableAlias(rightTableAlias);
+        }
         tableInfo.setLeftIsSideTable(leftIsSide);
         tableInfo.setRightIsSideTable(rightIsSide);
         tableInfo.setLeftNode(leftNode);