去掉重复的字段注册

zoudaokoulife · zoudaokoulife · commit 8ab5fb06f17a · 2020-02-21T15:06:46.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
@@ -865,7 +865,7 @@ private void joinFun(Object pollObj, Map<String, Table> localTableCache,
         replaceInfoList.add(replaceInfo);
 
         if (!tableEnv.isRegistered(joinInfo.getNewTableName())){
-            Table joinTable = tableEnv.fromDataStream(dsOut, String.join(",", sideOutTypeInfo.getFieldNames()));
+            Table joinTable = tableEnv.fromDataStream(dsOut);
             tableEnv.registerTable(joinInfo.getNewTableName(), joinTable);
             localTableCache.put(joinInfo.getNewTableName(), joinTable);
         }

Original file line number	Diff line number	Diff line change
`@@ -865,7 +865,7 @@ private void joinFun(Object pollObj, Map<String, Table> localTableCache,`
`865`	`865`	`replaceInfoList.add(replaceInfo);`
`866`	`866`
`867`	`867`	`if (!tableEnv.isRegistered(joinInfo.getNewTableName())){`
`868`		`- Table joinTable = tableEnv.fromDataStream(dsOut, String.join(",", sideOutTypeInfo.getFieldNames()));`
	`868`	`+ Table joinTable = tableEnv.fromDataStream(dsOut);`
`869`	`869`	`tableEnv.registerTable(joinInfo.getNewTableName(), joinTable);`
`870`	`870`	`localTableCache.put(joinInfo.getNewTableName(), joinTable);`
`871`	`871`	`}`