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;
}