维表表名替换逻辑

Author: dapeng

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

@@ -181,12 +181,12 @@ public static SqlIdentifier createNewIdentify(SqlIdentifier sqlIdentifier,
             return sqlIdentifier;
         }
 
+        sqlIdentifier = sqlIdentifier.setName(0, newTbName);
+
         String mappingFieldName = mappingField.get(fieldName);
         if(mappingFieldName == null){
             return sqlIdentifier;
         }
-
-        sqlIdentifier = sqlIdentifier.setName(0, newTbName);
         sqlIdentifier = sqlIdentifier.setName(1, mappingFieldName);
         return sqlIdentifier;
     }