Merge pull request #43 from zshao/issue_42_use_step1out

Fix a bug in MetastoreReplicationJob to use step1 output for step3 in…
airbnb · Nov 4, 2016 · ac899fc · ac899fc
2 parents 74ead4a + b3d4ce3
commit ac899fc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/main/src/main/java/com/airbnb/reair/batch/hive/MetastoreReplicationJob.java b/main/src/main/java/com/airbnb/reair/batch/hive/MetastoreReplicationJob.java
@@ -297,10 +297,10 @@ public int run(String[] args) throws Exception {
  LOG.info("Deleting " + step3Out);
  FsUtils.deleteDirectory(this.getConf(), step3Out);
  if (cl.hasOption("override-input")) {
- step2Out = new Path(cl.getOptionValue("override-input"));
+ step1Out = new Path(cl.getOptionValue("override-input"));
  }
 
- return this.runCommitChangeJob(new Path(step2Out, "part*"), step3Out);
+ return this.runCommitChangeJob(new Path(step1Out, "part*"), step3Out);
  default:
  LOG.error("Invalid step specified: " + step);
  return 1;