lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2392] Do not send partition delete record when changelog mode enabled (#3586)

Browse Source
This commit is contained in:
Danny Chan
2021-09-02 20:58:12 +08:00
committed by GitHub
parent 7a1bd225ca
commit 79b896f071
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java
View File

@@ -109,7 +109,8 @@ public class BucketAssignFunction<K, I, O extends HoodieRecord<?>>
this.conf = conf; this.conf = conf;
this.isChangingRecords = WriteOperationType.isChangingRecords( this.isChangingRecords = WriteOperationType.isChangingRecords(
WriteOperationType.fromValue(conf.getString(FlinkOptions.OPERATION))); 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 @Override