This is an automated email from the ASF dual-hosted git repository. pwason pushed a commit to branch release-0.14.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 605eb24b226fa7131a3f76c70946369564f630cd Author: zhuanshenbsj1 <[email protected]> AuthorDate: Mon Sep 4 09:56:52 2023 +0800 [HUDI-6808] SkipCompaction Config should not affect the stream read of the cow table (#9584) --- .../src/main/java/org/apache/hudi/source/IncrementalInputSplits.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java index fd6534d7f76..05d11bf746f 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java @@ -603,7 +603,7 @@ public class IncrementalInputSplits implements Serializable { @VisibleForTesting public HoodieTimeline filterInstantsAsPerUserConfigs(HoodieTimeline timeline) { final HoodieTimeline oriTimeline = timeline; - if (this.skipCompaction) { + if (OptionsResolver.isMorTable(this.conf) & this.skipCompaction) { // the compaction commit uses 'commit' as action which is tricky timeline = timeline.filter(instant -> !instant.getAction().equals(HoodieTimeline.COMMIT_ACTION)); }
