From a2df38df54dc60d6ad1f8dc3ed79b6459b6a22ec Mon Sep 17 00:00:00 2001
From: HouliangQi <neuyilan@163.com>
Date: Sun, 26 Jan 2025 16:17:38 +0800
Subject: [PATCH] revert the utils changes

---
 .../compact/MergeFunctionTestUtils.java          | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/paimon-core/src/test/java/org/apache/paimon/mergetree/compact/MergeFunctionTestUtils.java b/paimon-core/src/test/java/org/apache/paimon/mergetree/compact/MergeFunctionTestUtils.java
index 556336bbc451..97410c71717e 100644
--- a/paimon-core/src/test/java/org/apache/paimon/mergetree/compact/MergeFunctionTestUtils.java
+++ b/paimon-core/src/test/java/org/apache/paimon/mergetree/compact/MergeFunctionTestUtils.java
@@ -81,10 +81,18 @@ public static List<ReusingTestData> getExpectedForAggSum(List<ReusingTestData> i
 
         List<ReusingTestData> expected = new ArrayList<>();
         for (List<ReusingTestData> group : groups.values()) {
-            long sum =
-                    group.stream().mapToLong(d -> d.valueKind.isAdd() ? d.value : -d.value).sum();
-            ReusingTestData last = group.get(group.size() - 1);
-            expected.add(new ReusingTestData(last.key, last.sequenceNumber, RowKind.INSERT, sum));
+            if (group.size() == 1) {
+                // due to ReducerMergeFunctionWrapper
+                expected.add(group.get(0));
+            } else {
+                long sum =
+                        group.stream()
+                                .mapToLong(d -> d.valueKind.isAdd() ? d.value : -d.value)
+                                .sum();
+                ReusingTestData last = group.get(group.size() - 1);
+                expected.add(
+                        new ReusingTestData(last.key, last.sequenceNumber, RowKind.INSERT, sum));
+            }
         }
         return expected;
     }