diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java index b37558c..f5e546c 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java @@ -3337,6 +3337,7 @@ public static String getVertexCounterName(String counter, String vertexName) { PerfLogger perfLogger = SessionState.getPerfLogger(); perfLogger.PerfLogBegin(CLASS_NAME, PerfLogger.INPUT_PATHS); + FileSystem fileSystem = FileSystem.get(job); Set pathsProcessed = new HashSet(); List pathsToAdd = new LinkedList(); LockedDriverState lDrvStat = LockedDriverState.getLockedDriverState(); @@ -3365,6 +3366,7 @@ public static String getVertexCounterName(String counter, String vertexName) { } Path file = e.getKey(); + if (fileSystem.exists(file)) { List aliases = e.getValue(); if (aliases.contains(alias)) { if (file != null) { @@ -3390,6 +3392,7 @@ public static String getVertexCounterName(String counter, String vertexName) { } pathsToAdd.add(file); + } } }