field replace

todd5167 · todd5167 · commit a39b82d6ae7b · 2019-09-04T12:02:56.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java b/core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java
@@ -363,7 +363,7 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
             SqlIdentifier sqlIdentifier = (SqlIdentifier) selectNode;
 
             if(sqlIdentifier.names.size() == 1){
-                return null;
+                return selectNode;
             }
 
             String mappingFieldName = mappingTable.get(sqlIdentifier.getComponent(0).getSimple(), sqlIdentifier.getComponent(1).getSimple());

Original file line number	Diff line number	Diff line change
`@@ -363,7 +363,7 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String`
`363`	`363`	`SqlIdentifier sqlIdentifier = (SqlIdentifier) selectNode;`
`364`	`364`
`365`	`365`	`if(sqlIdentifier.names.size() == 1){`
`366`		`- return null;`
	`366`	`+ return selectNode;`
`367`	`367`	`}`
`368`	`368`
`369`	`369`	`String mappingFieldName = mappingTable.get(sqlIdentifier.getComponent(0).getSimple(), sqlIdentifier.getComponent(1).getSimple());`