diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java index eefa1d9..f70e339 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java @@ -1010,6 +1010,10 @@ public LocalResource localizeResource( } copyNotifiers.remove(srcStr, notifier); } catch (IOException e) { + if ("Exception while contacting value generator".equals(e.getMessage())) { + throw new IOException("copyFromLocalFile failed due to HDFS KMS failure"); + } + LOG.info("Looks like another thread or process is writing the same file"); int waitAttempts = HiveConf.getIntVar( conf, ConfVars.HIVE_LOCALIZE_RESOURCE_NUM_WAIT_ATTEMPTS);