diff --git common/src/java/org/apache/hadoop/hive/common/metrics/Metrics.java common/src/java/org/apache/hadoop/hive/common/metrics/Metrics.java index 01c9d1d..cb59cf3 100644 --- common/src/java/org/apache/hadoop/hive/common/metrics/Metrics.java +++ common/src/java/org/apache/hadoop/hive/common/metrics/Metrics.java @@ -175,7 +175,7 @@ public static Long incrementCounter(String name, long increment) throws IOExcept } Long value; synchronized(metrics) { - if (!metrics.hasKey(name)) { + if (!metrics.hasKey(name) || get(name)==null) { value = Long.valueOf(increment); set(name, value); } else {