flinkSql字段名忽略大小写

dengdejiushini · dengdejiushini · commit ee15d5471101 · 2019-12-25T12:00:57.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/exec/FlinkSQLExec.java b/core/src/main/java/com/dtstack/flink/sql/exec/FlinkSQLExec.java
@@ -84,7 +84,6 @@ public static void sqlUpdate(StreamTableEnvironment tableEnv, String stmt, Strea
             tableEnv.insertInto(newTable, targetTableName, config);
         }catch (Exception ex){
             newTable = queryResult.select( String.join(",", ignoreCase(queryResult, fieldNames)));
-            System.out.println(String.join(",",fieldNames));
             tableEnv.insertInto(newTable, targetTableName, config);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,6 @@ public static void sqlUpdate(StreamTableEnvironment tableEnv, String stmt, Strea`
`84`	`84`	`tableEnv.insertInto(newTable, targetTableName, config);`
`85`	`85`	`}catch (Exception ex){`
`86`	`86`	`newTable = queryResult.select( String.join(",", ignoreCase(queryResult, fieldNames)));`
`87`		`- System.out.println(String.join(",",fieldNames));`
`88`	`87`	`tableEnv.insertInto(newTable, targetTableName, config);`
`89`	`88`	`}`
`90`	`89`