This is an automated email from the ASF dual-hosted git repository.
jlli pushed a commit to branch fix-DistinctCountThetaSketchAggregationFunction
in repository https://gitbox.apache.org/repos/asf/pinot.git
commit 577e5e2c58c26fa16ac7a692c0741ed47033cc63
Author: jlli_LinkedIn <j...@linkedin.com>
AuthorDate: Wed Jan 31 19:09:32 2024 -0800
Fix backward compatible issue in DistinctCountThetaSketchAggregationFunction
---
.../function/DistinctCountThetaSketchAggregationFunction.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountThetaSketchAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountThetaSketchAggregationFunction.java
index 83709857f9..34afe70d37 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountThetaSketchAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountThetaSketchAggregationFunction.java
@@ -1024,7 +1024,8 @@ public class DistinctCountThetaSketchAggregationFunction
int numAccumulators = accumulators.size();
List<Sketch> mergedSketches = new ArrayList<>(numAccumulators);
- for (ThetaSketchAccumulator accumulator : accumulators) {
+ for (Object accumulatorObject : accumulators) {
+ ThetaSketchAccumulator accumulator =
convertSketchAccumulator(accumulatorObject);
accumulator.setThreshold(_accumulatorThreshold);
accumulator.setSetOperationBuilder(_setOperationBuilder);
mergedSketches.add(accumulator.getResult());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
