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

JingsongLi 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 09997f288c [core] rename FileStoreCommitImpl var name (#9457)
09997f288c is described below

commit 09997f288cca785f0d9aae4c917c059cf82c5235
Author: weijie <[email protected]>
AuthorDate: Sat Aug 29 20:54:23 2026 +0800

    [core] rename FileStoreCommitImpl var name (#9457)
---
 .../org/apache/paimon/operation/FileStoreCommitImpl.java     | 12 ++++++------
 1 file changed, 6 insertions(+), 6 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 2809101551..49a231821c 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
@@ -1097,7 +1097,7 @@ public class FileStoreCommitImpl implements 
FileStoreCommit {
         Snapshot newSnapshot;
         Pair<String, Long> baseManifestList = null;
         Pair<String, Long> deltaManifestList = null;
-        List<PartitionEntry> deltaStatistics;
+        List<PartitionEntry> deltaPartitionEntries;
         Pair<String, Long> changelogManifestList = null;
         String oldIndexManifest = null;
         String indexManifest = null;
@@ -1173,7 +1173,7 @@ public class FileStoreCommitImpl implements 
FileStoreCommit {
             long totalRecordCount = previousTotalRecordCount + 
deltaRecordCount;
 
             // write new delta files into manifest files
-            deltaStatistics = new 
ArrayList<>(PartitionEntry.merge(deltaFiles));
+            deltaPartitionEntries = new 
ArrayList<>(PartitionEntry.merge(deltaFiles));
             deltaManifestList = 
manifestList.write(manifestFile.write(deltaFiles));
 
             // write changelog into manifest files
@@ -1263,7 +1263,7 @@ public class FileStoreCommitImpl implements 
FileStoreCommit {
                 callback ->
                         callback.call(finalBaseFiles, finalDeltaFiles, 
indexFiles, newSnapshot));
         try {
-            success = commitSnapshotImpl(latestSnapshot, newSnapshot, 
deltaStatistics);
+            success = commitSnapshotImpl(latestSnapshot, newSnapshot, 
deltaPartitionEntries);
         } catch (Exception e) {
             // commit exception, not sure about the situation and should not 
clean up the files
             LOG.warn(
@@ -1666,10 +1666,10 @@ public class FileStoreCommitImpl implements 
FileStoreCommit {
     private boolean commitSnapshotImpl(
             @Nullable Snapshot baseSnapshot,
             Snapshot newSnapshot,
-            List<PartitionEntry> deltaStatistics) {
+            List<PartitionEntry> deltaPartitionEntries) {
         try {
-            List<PartitionStatistics> statistics = new 
ArrayList<>(deltaStatistics.size());
-            for (PartitionEntry entry : deltaStatistics) {
+            List<PartitionStatistics> statistics = new 
ArrayList<>(deltaPartitionEntries.size());
+            for (PartitionEntry entry : deltaPartitionEntries) {
                 statistics.add(entry.toPartitionStatistics(partitionComputer));
             }
             return snapshotCommit.commit(

Reply via email to