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