Fix error message in HyperUniquesAggregatorFactory

apache · Jul 3, 2024 · d5af441 · d5af441
1 parent 90d8e16
commit d5af441
Showing 1 changed file with 6 additions and 9 deletions.
diff --git a/...in/java/org/apache/druid/query/aggregation/hyperloglog/HyperUniquesAggregatorFactory.java b/...in/java/org/apache/druid/query/aggregation/hyperloglog/HyperUniquesAggregatorFactory.java
@@ -107,11 +107,10 @@ public Aggregator factorize(ColumnSelectorFactory metricFactory)
     if (columnCapabilities != null) {
       final ColumnType type = columnCapabilities.toColumnType();
       if (!ColumnType.UNKNOWN_COMPLEX.equals(type) && !TYPE.equals(type) && !PRECOMPUTED_TYPE.equals(type)) {
-        throw new UOE("Using aggregation type %s is not supported for %s<%s> column. "
+        throw new UOE("Using aggregation type %s is not supported for %s column. "
                       + "Use a different aggregator type and run the query again.",
                       getIntermediateType().getComplexTypeName(),
-                      type,
-                      type.getComplexTypeName());
+                      type);
       }
     }
 
@@ -129,11 +128,10 @@ public BufferAggregator factorizeBuffered(ColumnSelectorFactory metricFactory)
     if (columnCapabilities != null) {
       final ColumnType type = columnCapabilities.toColumnType();
       if (!ColumnType.UNKNOWN_COMPLEX.equals(type) && !TYPE.equals(type) && !PRECOMPUTED_TYPE.equals(type)) {
-        throw new UOE("Using aggregation type %s is not supported for %s<%s> column. "
+        throw new UOE("Using aggregation type %s is not supported for %s column. "
                       + "Use a different aggregator type and run the query again.",
                       getIntermediateType().getComplexTypeName(),
-                      type,
-                      type.getComplexTypeName());
+                      type);
       }
     }
 
@@ -151,11 +149,10 @@ public VectorAggregator factorizeVector(final VectorColumnSelectorFactory select
     if (columnCapabilities != null) {
       final ColumnType type = columnCapabilities.toColumnType();
       if (!ColumnType.UNKNOWN_COMPLEX.equals(type) && !TYPE.equals(type) && !PRECOMPUTED_TYPE.equals(type)) {
-        throw new UOE("Using aggregation type %s is not supported for %s<%s> column. "
+        throw new UOE("Using aggregation type %s is not supported for %s column. "
                       + "Use a different aggregator type and run the query again.",
                       getIntermediateType().getComplexTypeName(),
-                      type,
-                      type.getComplexTypeName());
+                      type);
       }
     }