From cb5cd35991afa2ed5b14ad92f2b98ae341fee9c4 Mon Sep 17 00:00:00 2001
From: swuferhong <337361684@qq.com>
Date: Tue, 22 Jun 2021 08:53:54 +0800
Subject: [PATCH] [HUDI-2043]
 HoodieDefaultTimeline$filterPendingCompactionTImeline() method have wrong
 filter condition (#3109)

---
 .../hudi/common/table/timeline/HoodieDefaultTimeline.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java
index c7d61a732..d4bf2dd20 100644
--- a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java
+++ b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java
@@ -127,7 +127,7 @@ public class HoodieDefaultTimeline implements HoodieTimeline {
   @Override
   public HoodieTimeline filterPendingCompactionTimeline() {
     return new HoodieDefaultTimeline(
-        instants.stream().filter(s -> s.getAction().equals(HoodieTimeline.COMPACTION_ACTION)), details);
+        instants.stream().filter(s -> s.getAction().equals(HoodieTimeline.COMPACTION_ACTION) && !s.isCompleted()), details);
   }
 
   @Override