public static void insertInto(StreamTableEnvironment tableEnv,
                                  SqlNode sqlNode,
                                  String targetTableName,
                                  Table fromTable,
                                  Collection<String> newRegisterTableList){
        boolean isGroupByTimeWindow = TableUtils.checkIsDimTableGroupBy(sqlNode, newRegisterTableList);
        if(isGroupByTimeWindow){
            QueryOperationConverter.setProducesUpdates(true);
        }

        tableEnv.insertInto(targetTableName, fromTable);
        QueryOperationConverter.setProducesUpdates(false);
    }
@description: mapping by name when insert into sink table
@author: maqi
@create: 2019/08/15 11:09
core/src/main/java/com/dtstack/flink/sql/exec/FlinkSQLExec.java