Skip to content

Commit 4d6987a

Browse files
authored
[core] Change commit.callbacks order (#6636)
1 parent 28eb2ac commit 4d6987a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -370,8 +370,7 @@ public InternalRowPartitionComputer partitionComputer() {
370370
}
371371

372372
private List<CommitCallback> createCommitCallbacks(String commitUser, FileStoreTable table) {
373-
List<CommitCallback> callbacks =
374-
new ArrayList<>(CallbackUtils.loadCommitCallbacks(options, table));
373+
List<CommitCallback> callbacks = new ArrayList<>();
375374

376375
if (options.partitionedTableInMetastore() && !schema.partitionKeys().isEmpty()) {
377376
PartitionHandler partitionHandler = catalogEnvironment.partitionHandler();
@@ -401,6 +400,7 @@ private List<CommitCallback> createCommitCallbacks(String commitUser, FileStoreT
401400
callbacks.add(new IcebergCommitCallback(table, commitUser));
402401
}
403402

403+
callbacks.addAll(CallbackUtils.loadCommitCallbacks(options, table));
404404
return callbacks;
405405
}
406406

0 commit comments

Comments
 (0)