(incubator-paimon) branch master updated: [core] Only bulkLoadBootstrapRecords for Deduplicate in GlobalIndexAssigner

[lzljs3620320]

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/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new c3ff5c34c [core] Only bulkLoadBootstrapRecords for Deduplicate in 
GlobalIndexAssigner
c3ff5c34c is described below

commit c3ff5c34ce1b612d2f456043e41f258043d7d6cc
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Tue Oct 31 14:15:44 2023 +0800

    [core] Only bulkLoadBootstrapRecords for Deduplicate in GlobalIndexAssigner
---
 .../main/java/org/apache/paimon/crosspartition/GlobalIndexAssigner.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/crosspartition/GlobalIndexAssigner.java
 
b/paimon-core/src/main/java/org/apache/paimon/crosspartition/GlobalIndexAssigner.java
index 2dfbc7075..6450d07fc 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/crosspartition/GlobalIndexAssigner.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/crosspartition/GlobalIndexAssigner.java
@@ -225,7 +225,7 @@ public class GlobalIndexAssigner implements Serializable, 
Closeable {
         bootstrapKeys.clear();
         bootstrapKeys = null;
 
-        if (isEmpty && isEndInput) {
+        if (isEmpty && isEndInput && table.coreOptions().mergeEngine() == 
MergeEngine.DEDUPLICATE) {
             // optimization: bulk load mode
             bulkLoadBootstrapRecords();
         } else {