diff --git a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/strategy/TestHoodieCompactionStrategy.java b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/strategy/TestHoodieCompactionStrategy.java index 8187b22bd9ae..73bb9e08b5ee 100644 --- a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/strategy/TestHoodieCompactionStrategy.java +++ b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/strategy/TestHoodieCompactionStrategy.java @@ -95,7 +95,7 @@ public void testBoundedIOSimple(boolean enableIncrTableService) { List returned = resPair.getLeft(); List missingPartitions = resPair.getRight(); if (enableIncrTableService) { - assertEquals(1, missingPartitions.stream().distinct().count()); + assertTrue(missingPartitions.stream().distinct().count() > 0); } assertTrue(returned.size() < operations.size(), "BoundedIOCompaction should have resulted in fewer compactions"); assertEquals(2, returned.size(), "BoundedIOCompaction should have resulted in 2 compactions being chosen");