account for null values in the stddev post aggregator (#15660)

apache · Jan 16, 2024 · 8ba06cf · 8ba06cf
1 parent 6b951b9
commit 8ba06cf
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...ain/java/org/apache/druid/query/aggregation/variance/StandardDeviationPostAggregator.java b/...ain/java/org/apache/druid/query/aggregation/variance/StandardDeviationPostAggregator.java
@@ -79,7 +79,11 @@ public Comparator<Double> getComparator()
   @Nullable
   public Double compute(Map<String, Object> combinedAggregators)
   {
-    Double variance = ((VarianceAggregatorCollector) combinedAggregators.get(fieldName)).getVariance(isVariancePop);
+    Object varianceAggregatorCollector = combinedAggregators.get(fieldName);
+    if (!(varianceAggregatorCollector instanceof VarianceAggregatorCollector)) {
+      return NullHandling.defaultDoubleValue();
+    }
+    Double variance = ((VarianceAggregatorCollector) varianceAggregatorCollector).getVariance(isVariancePop);
     return variance == null ? NullHandling.defaultDoubleValue() : (Double) Math.sqrt(variance);
   }