diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java index 055decdd49..062f367f6b 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java @@ -203,11 +203,11 @@ private void initiateDataCopyTasks() throws SemanticException { } private void finishRemainingTasks() throws SemanticException { - prepareReturnValues(work.getResultValues()); Path dumpAckFile = new Path(work.getCurrentDumpPath(), ReplUtils.REPL_HIVE_BASE_DIR + File.separator + ReplAck.DUMP_ACKNOWLEDGEMENT.toString()); Utils.create(dumpAckFile, conf); + prepareReturnValues(work.getResultValues()); deleteAllPreviousDumpMeta(work.getCurrentDumpPath()); } diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java index 3b49801138..44320a5932 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/dump/Utils.java @@ -127,7 +127,7 @@ public static void create(Path outputFile, HiveConf hiveConf) @Override public Void execute() throws IOException { FileSystem fs = outputFile.getFileSystem(hiveConf); - fs.create(outputFile); + fs.create(outputFile).close(); return null; } };