From 113d91485895f7839f978b34d5380b42cdec10e8 Mon Sep 17 00:00:00 2001
From: Maksim Timonin <timonin.maxim@gmail.com>
Date: Sat, 28 Dec 2024 15:56:11 +0300
Subject: [PATCH] Remove lambda from addOnReducer

---
 .../processors/query/calcite/exec/rel/HashAggregateNode.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateNode.java
index 9751e4273f296..42eefa7462e92 100644
--- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateNode.java
+++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateNode.java
@@ -332,10 +332,10 @@ private void addOnReducer(Row row) {
 
             GroupKey grpKey = (GroupKey)handler.get(1, row);
 
-            List<AccumulatorWrapper<Row>> wrappers = groups.computeIfAbsent(grpKey, (k) -> create());
+            List<AccumulatorWrapper<Row>> wrappers = groups.get(grpKey);
             Accumulator<Row>[] accums = hasAccumulators() ? (Accumulator<Row>[])handler.get(2, row) : null;
 
-            for (int i = 0; i < wrappers.size(); i++) {
+            for (int i = 0; i < F.size(wrappers); i++) {
                 AccumulatorWrapper<Row> wrapper = wrappers.get(i);
                 Accumulator<Row> accum = accums[i];