public static Configuration getFlinkConfiguration(String flinkConfDir, Properties confProperties) {
        Configuration flinkConfig = StringUtils.isEmpty(flinkConfDir) ? new Configuration() : GlobalConfiguration.loadConfiguration(flinkConfDir);

        confProperties.forEach((key, val) -> flinkConfig.setString(key.toString(), val.toString()));
        return flinkConfig;
    }
build JobGraph by JobParamsInfo
Date: 2020/3/4
Company: www.dtstack.com
@author maqi
launcher/src/main/java/com/dtstack/flink/sql/launcher/utils/JobGraphBuildUtil.java