diff --git spark-client/src/main/java/org/apache/hive/spark/counter/SparkCounterGroup.java spark-client/src/main/java/org/apache/hive/spark/counter/SparkCounterGroup.java index ea1b7ee..57d5289 100644 --- spark-client/src/main/java/org/apache/hive/spark/counter/SparkCounterGroup.java +++ spark-client/src/main/java/org/apache/hive/spark/counter/SparkCounterGroup.java @@ -21,7 +21,6 @@ import java.util.HashMap; import java.util.Map; -import org.apache.hadoop.hive.shims.ShimLoader; import org.apache.spark.api.java.JavaSparkContext; /** @@ -47,8 +46,7 @@ public SparkCounterGroup( } public void createCounter(String name, long initValue) { - String displayName = ShimLoader.getHadoopShims().getCounterGroupName(groupName, groupName); - SparkCounter counter = new SparkCounter(name, displayName, groupName, initValue, javaSparkContext); + SparkCounter counter = new SparkCounter(name, name, groupName, initValue, javaSparkContext); sparkCounters.put(name, counter); } diff --git spark-client/src/main/java/org/apache/hive/spark/counter/SparkCounters.java spark-client/src/main/java/org/apache/hive/spark/counter/SparkCounters.java index 95b8f0b..955538e 100644 --- spark-client/src/main/java/org/apache/hive/spark/counter/SparkCounters.java +++ spark-client/src/main/java/org/apache/hive/spark/counter/SparkCounters.java @@ -107,9 +107,7 @@ public SparkCounter getCounter(Enum key) { private SparkCounterGroup getGroup(String groupName) { SparkCounterGroup group = sparkCounterGroups.get(groupName); if (group == null) { - String groupDisplayName = - ShimLoader.getHadoopShims().getCounterGroupName(groupName, groupName); - group = new SparkCounterGroup(groupName, groupDisplayName, javaSparkContext); + group = new SparkCounterGroup(groupName, groupName, javaSparkContext); sparkCounterGroups.put(groupName, group); } return group;