You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2023/10/31 06:16:14 UTC

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

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 <ji...@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 {