flinkSql字段名大小写忽略

dengdejiushini · dengdejiushini · commit d1f6114e8e3e · 2019-12-25T14:52:15.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
@@ -92,7 +92,6 @@ public static void sqlUpdate(StreamTableEnvironment tableEnv, String stmt, Strea
             newTable = queryResult.select(String.join(",", ignoreCase(queryFieldNames, sinkFieldNames)));
             tableEnv.insertInto(newTable, targetTableName, config);
         }
-
     }
 
     public static String[] ignoreCase(String[] queryFieldNames, String[] sinkFieldNames) {

Original file line number	Diff line number	Diff line change
`@@ -92,7 +92,6 @@ public static void sqlUpdate(StreamTableEnvironment tableEnv, String stmt, Strea`
`92`	`92`	`newTable = queryResult.select(String.join(",", ignoreCase(queryFieldNames, sinkFieldNames)));`
`93`	`93`	`tableEnv.insertInto(newTable, targetTableName, config);`
`94`	`94`	`}`
`95`		`-`
`96`	`95`	`}`
`97`	`96`
`98`	`97`	`public static String[] ignoreCase(String[] queryFieldNames, String[] sinkFieldNames) {`