From 3a2bf4d2ed0d17e5410cae7bd181702d7e8ad49b Mon Sep 17 00:00:00 2001
From: Zheng Shao <zheng@uber.com>
Date: Thu, 3 Nov 2016 16:19:39 -0700
Subject: [PATCH] Fix a bug in MetastoreReplicationJob to use step1 output for
 step3 in step-by-step mode.

---
 .../com/airbnb/reair/batch/hive/MetastoreReplicationJob.java  | 4 ++--
 1 file changed, 2 insertions(+), 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
index 49da5ad6..07bbee43 100644
--- 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;