Merge branch '1.5_3.6.1_field_replace' into '1.5_v3.6.1'

zoudaokoulife · zoudaokoulife · commit 2c139339d3b6 · 2019-09-04T13:54:03.000+08:00
属性替换

s

See merge request !63
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());`