diff --git a/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java b/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java index 5c9d26f08..15dbae6df 100644 --- a/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java +++ b/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java @@ -109,7 +109,8 @@ public class BucketAssignFunction> this.conf = conf; this.isChangingRecords = WriteOperationType.isChangingRecords( WriteOperationType.fromValue(conf.getString(FlinkOptions.OPERATION))); - this.globalIndex = conf.getBoolean(FlinkOptions.INDEX_GLOBAL_ENABLED); + this.globalIndex = conf.getBoolean(FlinkOptions.INDEX_GLOBAL_ENABLED) + && !conf.getBoolean(FlinkOptions.CHANGELOG_ENABLED); } @Override