diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java index b13f73b..fe139c9 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java @@ -132,7 +132,7 @@ public HiveResources(Path dagResourcesDir) { } /** A directory that will contain resources related to DAGs and specified in configs. */ public final Path dagResourcesDir; - public final Set additionalFilesNotFromConf = new HashSet<>(); + public final Map additionalFilesNotFromConf = new HashMap(); /** Localized resources of this session; both from conf and not from conf (above). */ public final Set localizedResources = new HashSet<>(); @@ -595,7 +595,7 @@ public void ensureLocalResources(Configuration conf, String[] newFilesNotFromCon boolean hasResources = !resources.additionalFilesNotFromConf.isEmpty(); if (hasResources) { for (String s : newFilesNotFromConf) { - hasResources = resources.additionalFilesNotFromConf.contains(s); + hasResources = resources.additionalFilesNotFromConf.keySet().contains(s); if (!hasResources) { break; } @@ -607,9 +607,11 @@ public void ensureLocalResources(Configuration conf, String[] newFilesNotFromCon if (newResources != null) { resources.localizedResources.addAll(newResources); } - for (String fullName : newFilesNotFromConf) { - resources.additionalFilesNotFromConf.add(fullName); + for (int i=0;i