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 8c2bd0543b..10c5c7f554 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 @@ -311,8 +311,11 @@ private void prepareReturnValues(List values) throws SemanticException { } private void deleteAllPreviousDumpMeta(Path currentDumpPath) { + Path dumpRoot = getDumpRoot(currentDumpPath); + if(dumpRoot == null) { + return; + } try { - Path dumpRoot = getDumpRoot(currentDumpPath); FileSystem fs = dumpRoot.getFileSystem(conf); if (fs.exists(dumpRoot)) { FileStatus[] statuses = fs.listStatus(dumpRoot,