fix

Author: Alibaba-HZY

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlinkTableSourceITCase.java

@@ -1189,7 +1189,7 @@ void testStreamingReadPartitionPushDownWithInExpr() throws Exception {
                         .stream()
                         .filter(s -> s.contains("2025") || s.contains("2026"))
                         .collect(Collectors.toList());
-        waitUtilAllBucketFinishSnapshot(admin, tablePath, Arrays.asList("2025", "2026", "2027"));
+        waitUntilAllBucketFinishSnapshot(admin, tablePath, Arrays.asList("2025", "2026", "2027"));
 
         String plan =
                 tEnv.explainSql("select * from partitioned_table_in where c in ('2025','2026')");
@@ -1247,7 +1247,7 @@ void testStreamingReadWithCombinedFiltersAndInExpr() throws Exception {
         }
 
         writeRows(conn, tablePath, rows, false);
-        waitUtilAllBucketFinishSnapshot(admin, tablePath, Arrays.asList("2025", "2026", "2027"));
+        waitUntilAllBucketFinishSnapshot(admin, tablePath, Arrays.asList("2025", "2026", "2027"));
 
         String plan =
                 tEnv.explainSql(
@@ -1291,7 +1291,7 @@ void testStreamingReadPartitionPushDownWithLikeExpr() throws Exception {
                 allData.stream()
                         .filter(s -> s.contains("2025") || s.contains("2026"))
                         .collect(Collectors.toList());
-        waitUtilAllBucketFinishSnapshot(admin, tablePath, Arrays.asList("2025", "2026", "3026"));
+        waitUntilAllBucketFinishSnapshot(admin, tablePath, Arrays.asList("2025", "2026", "3026"));
 
         String plan = tEnv.explainSql("select * from partitioned_table_like where c like '202%'");
         assertThat(plan)
@@ -1350,7 +1350,7 @@ void testStreamingReadPartitionComplexPushDown() throws Exception {
                 allData.stream()
                         .filter(s -> s.contains("v3") && !s.contains("2025, 2"))
                         .collect(Collectors.toList());
-        waitUtilAllBucketFinishSnapshot(
+        waitUntilAllBucketFinishSnapshot(
                 admin, tablePath, Arrays.asList("2025$1", "2025$2", "2026$1"));
 
         String plan =