public static void main(String[] args) throws Exception {
        ParamsInfo paramsInfo = ExecuteProcessHelper.parseParams(args);
        StreamExecutionEnvironment env = ExecuteProcessHelper.getStreamExecution(paramsInfo);
        env.execute(paramsInfo.getName());
        LOG.info("program {} execution success", paramsInfo.getName());
    }
Date: 2018/6/26
Company: www.dtstack.com
@author xuchao
core/src/main/java/com/dtstack/flink/sql/Main.java