(paimon) branch master updated: [hotfix] Fix test WithPartialUpdateMergeFunctionTest (#5425)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 5988af160c [hotfix] Fix test WithPartialUpdateMergeFunctionTest (#5425)
5988af160c is described below

commit 5988af160cd20abb6d7dd8a0ada17d6920b83608
Author: yuzelin <33053040+yuze...@users.noreply.github.com>
AuthorDate: Wed Apr 9 14:56:36 2025 +0800

    [hotfix] Fix test WithPartialUpdateMergeFunctionTest (#5425)
---
 .../paimon/mergetree/compact/PartialUpdateMergeFunction.java      | 1 +
 .../apache/paimon/mergetree/compact/MergeFunctionTestUtils.java   | 8 +++-----
 2 files changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java
 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java
index faddc8c4ec..b24cf1edeb 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java
@@ -114,6 +114,7 @@ public class PartialUpdateMergeFunction implements 
MergeFunction<KeyValue> {
         this.meetInsert = false;
         this.notNullColumnFilled = false;
         this.row = new GenericRow(getters.length);
+        this.latestSequenceNumber = 0;
         fieldAggregators.values().forEach(FieldAggregator::reset);
     }
 
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 d52d1fa1f8..4acea88b2d 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
@@ -66,12 +66,10 @@ public class MergeFunctionTestUtils {
                 expected.add(group.get(group.size() - 1));
             } else {
                 if (group.stream().noneMatch(data -> data.valueKind == 
RowKind.INSERT)) {
-                    // No insert: fill the pk and left nullable fields to 
null; sequenceNumber =
-                    // latest
+                    // No insert: fill the pk and left nullable fields to 
null; sequenceNumber = 0
+                    // because it's not updated
                     ReusingTestData last = group.get(group.size() - 1);
-                    expected.add(
-                            new ReusingTestData(
-                                    last.key, last.sequenceNumber, 
RowKind.DELETE, null));
+                    expected.add(new ReusingTestData(last.key, 0, 
RowKind.DELETE, null));
                 } else {
                     // get the last INSERT data because later DELETE data are 
ignored
                     group.stream()