fix

JNSimba · Sep 10, 2024 · 7518568 · 7518568
1 parent 000f2b5
commit 7518568
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java
@@ -383,6 +383,7 @@ public void testJobManagerFailoverSource() throws Exception {
         }
         List<String> actual = fetchRows(iterator);
         LOG.info("actual data: {}, expected: {}", actual, expectedData);
+        Assert.assertTrue(actual.size() >= expectedData.size());
         Assert.assertTrue(actual.containsAll(expectedData));
     }
 
@@ -461,6 +462,7 @@ public void testTaskManagerFailoverSource() throws Exception {
 
         List<String> actual = fetchRows(iterator);
         LOG.info("actual data: {}, expected: {}", actual, expectedData);
+        Assert.assertTrue(actual.size() >= expectedData.size());
         Assert.assertTrue(actual.containsAll(expectedData));
     }