@ Override public void setupHadoopJobProperties ( ) { if ( getJobProps ( ) . containsKey ( HADOOP_GLOBAL_OPTS ) ) { String hadoopGlobalOps = getJobProps ( ) . getString ( HADOOP_GLOBAL_OPTS ) ; if ( getJobProps ( ) . containsKey ( HADOOP_OPTS ) ) { String hadoopOps = getJobProps ( ) . getString ( HADOOP_OPTS ) ; getJobProps ( ) . put ( HADOOP_OPTS , String . format ( "%s %s" , hadoopOps , hadoopGlobalOps ) ) ; } else { getJobProps ( ) . put ( HADOOP_OPTS , hadoopGlobalOps ) ; } } }
Append HADOOP_GLOBAL_OPTS with HADOOP_OPTS in the given props