diff --git a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/VarianceAggregationFunction.java b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/VarianceAggregationFunction.java index 753c96219d62..ca398ba39977 100644 --- a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/VarianceAggregationFunction.java +++ b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/VarianceAggregationFunction.java @@ -158,12 +158,10 @@ public VarianceTuple extractGroupByResult(GroupByResultHolder groupByResultHolde @Override public VarianceTuple merge(VarianceTuple intermediateResult1, VarianceTuple intermediateResult2) { - if (_nullHandlingEnabled) { - if (intermediateResult1 == null) { - return intermediateResult2; - } else if (intermediateResult2 == null) { - return intermediateResult1; - } + if (intermediateResult1 == null) { + return intermediateResult2; + } else if (intermediateResult2 == null) { + return intermediateResult1; } intermediateResult1.apply(intermediateResult2); return intermediateResult1;