main/src/main/java/com/airbnb/reair/batch/hive/MetastoreReplicationJob.java: Add number of reducers from config for Step1 runMetaStoreCompareJob

Author: uzshao

main/src/main/java/com/airbnb/reair/batch/hive/MetastoreReplicationJob.java

@@ -401,6 +401,10 @@ private int runMetastoreCompareJob(Path output)
     FileOutputFormat.setOutputPath(job, output);
     FileOutputFormat.setOutputCompressorClass(job, GzipCodec.class);
 
+    job.setNumReduceTasks(getConf().getInt(
+            ConfigurationKeys.BATCH_JOB_METASTORE_PARALLELISM,
+            150));
+
     boolean success = job.waitForCompletion(true);
 
     return success ? 0 : 1;
@@ -523,10 +527,6 @@ private int runCommitChangeJob(Path input, Path output)
     FileOutputFormat.setOutputPath(job, output);
     FileOutputFormat.setOutputCompressorClass(job, GzipCodec.class);
 
-    job.setNumReduceTasks(getConf().getInt(
-        ConfigurationKeys.BATCH_JOB_METASTORE_PARALLELISM,
-        150));
-
     boolean success = job.waitForCompletion(true);
 
     if (success) {