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 2809101551b4..49a231821c9f 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 @@ CommitResult tryCommitOnce( Snapshot newSnapshot; Pair baseManifestList = null; Pair deltaManifestList = null; - List deltaStatistics; + List deltaPartitionEntries; Pair changelogManifestList = null; String oldIndexManifest = null; String indexManifest = null; @@ -1173,7 +1173,7 @@ CommitResult tryCommitOnce( 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 @@ CommitResult tryCommitOnce( 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 @@ static CoreOptions manifestCompactionOptions( private boolean commitSnapshotImpl( @Nullable Snapshot baseSnapshot, Snapshot newSnapshot, - List deltaStatistics) { + List deltaPartitionEntries) { try { - List statistics = new ArrayList<>(deltaStatistics.size()); - for (PartitionEntry entry : deltaStatistics) { + List statistics = new ArrayList<>(deltaPartitionEntries.size()); + for (PartitionEntry entry : deltaPartitionEntries) { statistics.add(entry.toPartitionStatistics(partitionComputer)); } return snapshotCommit.commit(