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

        Table resultTable = tableEnv.sqlQuery(sqlNode.toString());
        QueryOperationConverter.setProducesUpdates(false);
        return resultTable;
    }
@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