private org.apache.hadoop.conf.Configuration loadHadoopConfigFromFlink() {
		org.apache.hadoop.conf.Configuration hadoopConfig = new org.apache.hadoop.conf.Configuration();
		for (String key : flinkConfig.keySet()) {
			for (String prefix : flinkConfigPrefixes) {
				if (key.startsWith(prefix)) {
					String newKey = hadoopConfigPrefix + key.substring(prefix.length());
					String newValue = fixHadoopConfig(key, flinkConfig.getString(key, null));
					hadoopConfig.set(newKey, newValue);

					LOG.debug("Adding Flink config entry for {} as {} to Hadoop config", key, newKey);
				}
			}
		}
		return hadoopConfig;
	}
private org . apache . hadoop . conf . Configuration loadHadoopConfigFromFlink ( ) { org . apache . hadoop . conf . Configuration hadoopConfig = new org . apache . hadoop . conf . Configuration ( ) ; for ( String key : flinkConfig . keySet ( ) ) { for ( String prefix : flinkConfigPrefixes ) { if ( key . startsWith ( prefix ) ) { String newKey = hadoopConfigPrefix + key . substring ( prefix . length ( ) ) ; String newValue = fixHadoopConfig ( key , flinkConfig . getString ( key , null ) ) ; hadoopConfig . set ( newKey , newValue ) ; LOG . debug ( "Adding Flink config entry for {} as {} to Hadoop config" , key , newKey ) ; } } } return hadoopConfig ; }
add additional config entries from the Flink config to the Hadoop config