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