rebase origin/master to fix CI

apache · May 20, 2022 · cf24598 · cf24598
1 parent 2b0c882
commit cf24598
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...connector/src/test/java/org/apache/flink/table/store/connector/ForceCompactionITCase.java b/...connector/src/test/java/org/apache/flink/table/store/connector/ForceCompactionITCase.java
@@ -110,7 +110,6 @@ public void testNoDefaultNumOfLevels() throws Exception {
                                 + "(9, 'Autumn', 'Wake Me Up When September Ends')")
                 .await();
 
-        assertThat(BlockingIterator.of(bEnv.executeSql("SELECT * FROM T1").collect()).collect())
-                .hasSize(15);
+        assertThat(batchSql("SELECT * FROM T1")).hasSize(15);
     }
 }