(paimon) branch master updated: [core] Support replacing index manifest in overwrite commit (#7855)

[junhao]

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

leaves12138 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 603ad8588a [core] Support replacing index manifest in overwrite commit 
(#7855)
603ad8588a is described below

commit 603ad8588a6691730652ff2abfc77dd59008f85d
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Thu May 14 19:16:27 2026 +0800

    [core] Support replacing index manifest in overwrite commit (#7855)
---
 .../apache/paimon/operation/FileStoreCommitImpl.java | 20 ++++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
 
b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
index 73f335fc02..8448a53fd9 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
@@ -1094,6 +1094,22 @@ public class FileStoreCommitImpl implements 
FileStoreCommit {
             long totalRecordCount,
             Pair<String, Long> baseManifestList,
             Pair<String, Long> deltaManifestList) {
+        return replaceManifestList(
+                latest,
+                totalRecordCount,
+                baseManifestList,
+                deltaManifestList,
+                latest.indexManifest(),
+                latest.nextRowId());
+    }
+
+    public boolean replaceManifestList(
+            Snapshot latest,
+            long totalRecordCount,
+            Pair<String, Long> baseManifestList,
+            Pair<String, Long> deltaManifestList,
+            @Nullable String indexManifest,
+            @Nullable Long nextRowId) {
         Snapshot newSnapshot =
                 new Snapshot(
                         latest.id() + 1,
@@ -1104,7 +1120,7 @@ public class FileStoreCommitImpl implements 
FileStoreCommit {
                         deltaManifestList.getRight(),
                         null,
                         null,
-                        latest.indexManifest(),
+                        indexManifest,
                         commitUser,
                         Long.MAX_VALUE,
                         CommitKind.OVERWRITE,
@@ -1116,7 +1132,7 @@ public class FileStoreCommitImpl implements 
FileStoreCommit {
                         latest.statistics(),
                         // if empty properties, just set to null
                         latest.properties(),
-                        latest.nextRowId());
+                        nextRowId);
 
         return commitSnapshotImpl(newSnapshot, emptyList());
     }