diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java index 2ea83ab..73263ee 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java @@ -171,8 +171,14 @@ public int execute(DriverContext driverContext) { } // fetch the counters - Set statusGetOpts = EnumSet.of(StatusGetOpts.GET_COUNTERS); - counters = client.getDAGStatus(statusGetOpts).getDAGCounters(); + try { + Set statusGetOpts = EnumSet.of(StatusGetOpts.GET_COUNTERS); + counters = client.getDAGStatus(statusGetOpts).getDAGCounters(); + } catch (Exception err) { + // Don't fail execution due to counters - just don't print summary info + LOG.error("Failed to get counters: " + err, err); + counters = null; + } TezSessionPoolManager.getInstance().returnSession(session); if (LOG.isInfoEnabled() && counters != null