fix const join side table as parse error

Author: a49a

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

@@ -75,12 +75,15 @@ public abstract class BaseSideInfo implements Serializable{
 
     protected AbstractSideCache sideCache;
 
+    protected JoinInfo joinInfo;
+
     public BaseSideInfo(RowTypeInfo rowTypeInfo, JoinInfo joinInfo, List<FieldInfo> outFieldInfoList,
                         AbstractSideTableInfo sideTableInfo){
         this.rowTypeInfo = rowTypeInfo;
         this.outFieldInfoList = outFieldInfoList;
         this.joinType = joinInfo.getJoinType();
         this.sideTableInfo = sideTableInfo;
+        this.joinInfo = joinInfo;
         parseSelectFields(joinInfo);
         buildEqualInfo(joinInfo, sideTableInfo);
     }
@@ -178,9 +181,7 @@ private void evalEquation(SqlIdentifier left, SqlIdentifier right, String sideTa
      */
     private void evalConstantEquation(SqlLiteral literal, SqlIdentifier identifier) {
         String tableName = identifier.getComponent(0).getSimple();
-        String sideTableName = sideTableInfo.getName();
-        String errorMsg = "only support set side table constant field, error field " + identifier;
-        Preconditions.checkState(tableName.equals(sideTableName), errorMsg);
+        checkSupport(identifier);
         String fieldName = identifier.getComponent(1).getSimple();
         Object constant = literal.getValue();
         List<PredicateInfo> predicateInfos = sideTableInfo.getPredicateInfoes();
@@ -194,6 +195,22 @@ private void evalConstantEquation(SqlLiteral literal, SqlIdentifier identifier)
         predicateInfos.add(predicate);
     }
 
+    private void checkSupport(SqlIdentifier identifier) {
+        String tableName = identifier.getComponent(0).getSimple();
+        String sideTableName;
+        String sideTableAlias;
+        if (joinInfo.isLeftIsSideTable()) {
+            sideTableName = joinInfo.getLeftTableName();
+            sideTableAlias = joinInfo.getLeftTableAlias();
+        } else {
+            sideTableName = joinInfo.getRightTableName();
+            sideTableAlias = joinInfo.getRightTableAlias();
+        }
+        boolean isSide = tableName.equals(sideTableName) || tableName.equals(sideTableAlias);
+        String errorMsg = "only support set side table constant field, error field " + identifier;
+        Preconditions.checkState(isSide, errorMsg);
+    }
+
     private void associateField(String sourceTableField, String sideTableField, SqlNode sqlNode) {
         String errorMsg = "can't deal equal field: " + sqlNode;
         equalFieldList.add(sideTableField);

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

@@ -55,15 +55,15 @@ public class JoinInfo implements Serializable {
 
     private String rightTableAlias;
 
-    private SqlNode leftNode;
+    private transient SqlNode leftNode;
 
-    private SqlNode rightNode;
+    private transient SqlNode rightNode;
 
-    private SqlNode condition;
+    private transient SqlNode condition;
 
-    private SqlNode selectFields;
+    private transient SqlNode selectFields;
 
-    private SqlNode selectNode;
+    private transient SqlNode selectNode;
 
     private JoinType joinType;