[hudi] 10/37: [HUDI-6808] SkipCompaction Config should not affect the stream read of the cow table (#9584)

[pw...@apache.org]

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 <34...@users.noreply.github.com>
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));
     }