private static TableSink getTableSinkByPlanner(StreamPlanner streamPlanner, String targetTableName)
            throws NoSuchMethodException, IllegalAccessException, InvocationTargetException {
        Method getTableSink = PlannerBase.class.getDeclaredMethod("getTableSink", ObjectIdentifier.class);
        getTableSink.setAccessible(true);
        ObjectIdentifier objectIdentifier = ObjectIdentifier.of(streamPlanner.catalogManager().getCurrentCatalog(), streamPlanner.catalogManager().getCurrentDatabase(), targetTableName);
        Option tableSinkOption = (Option) getTableSink.invoke(streamPlanner, objectIdentifier);
        return (TableSink) ((Tuple2) tableSinkOption.get())._2;
    }
@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