private static TableImpl extractQueryTableFromInsertCaluse(StreamTableEnvironmentImpl tableEnvImpl, FlinkPlannerImpl flinkPlanner, RichSqlInsert insert)
            throws NoSuchMethodException, IllegalAccessException, InvocationTargetException {
        StreamPlanner streamPlanner = (StreamPlanner) tableEnvImpl.getPlanner();
        Operation queryOperation = SqlToOperationConverter.convert(flinkPlanner, streamPlanner.catalogManager(), insert.getSource()).get();
        Method createTableMethod = TableEnvironmentImpl.class.getDeclaredMethod("createTable", QueryOperation.class);
        createTableMethod.setAccessible(true);
        return (TableImpl) createTableMethod.invoke(tableEnvImpl, queryOperation);
    }
@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