[hudi] branch master updated: [HUDI-6808] SkipCompaction Config should not affect the stream read of the cow table (#9584)

[danny0405]

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 52bc91e2e65 [HUDI-6808] SkipCompaction Config should not affect the 
stream read of the cow table (#9584)
52bc91e2e65 is described below

commit 52bc91e2e6573f08db9f3b0cc2408dc9a574a29f
Author: zhuanshenbsj1 <34104400+zhuanshenb...@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));
     }