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 4d6987ae90 [core] Change commit.callbacks order (#6636)
4d6987ae90 is described below

commit 4d6987ae9065c14c5ff4e43f2867e2b9c3f996b9
Author: Nikolay Volik <[email protected]>
AuthorDate: Fri Nov 21 06:25:22 2025 +0100

    [core] Change commit.callbacks order (#6636)
---
 paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java 
b/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java
index 4f48618ef8..5fa81383ce 100644
--- a/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java
+++ b/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java
@@ -370,8 +370,7 @@ abstract class AbstractFileStore<T> implements FileStore<T> 
{
     }
 
     private List<CommitCallback> createCommitCallbacks(String commitUser, 
FileStoreTable table) {
-        List<CommitCallback> callbacks =
-                new ArrayList<>(CallbackUtils.loadCommitCallbacks(options, 
table));
+        List<CommitCallback> callbacks = new ArrayList<>();
 
         if (options.partitionedTableInMetastore() && 
!schema.partitionKeys().isEmpty()) {
             PartitionHandler partitionHandler = 
catalogEnvironment.partitionHandler();
@@ -401,6 +400,7 @@ abstract class AbstractFileStore<T> implements FileStore<T> 
{
             callbacks.add(new IcebergCommitCallback(table, commitUser));
         }
 
+        callbacks.addAll(CallbackUtils.loadCommitCallbacks(options, table));
         return callbacks;
     }
 

Reply via email to