(fluss) branch main updated: [hotfix] Remove unstable "latest" scan startup mode test in ChangelogVirtualTableITCase (#2470)

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 1eff22969 [hotfix] Remove unstable "latest" scan startup mode test in 
ChangelogVirtualTableITCase (#2470)
1eff22969 is described below

commit 1eff229693abaa866307c2800ebcd10ab3a28021
Author: Jark Wu <j...@apache.org>
AuthorDate: Sun Jan 25 14:29:12 2026 +0800

    [hotfix] Remove unstable "latest" scan startup mode test in 
ChangelogVirtualTableITCase (#2470)
---
 .../fluss/flink/source/ChangelogVirtualTableITCase.java   | 15 +--------------
 1 file changed, 1 insertion(+), 14 deletions(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/ChangelogVirtualTableITCase.java
 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/ChangelogVirtualTableITCase.java
index 0135d3349..a1f3653ee 100644
--- 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/ChangelogVirtualTableITCase.java
+++ 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/ChangelogVirtualTableITCase.java
@@ -349,20 +349,7 @@ abstract class ChangelogVirtualTableITCase extends 
AbstractTestBase {
             assertThat(result).startsWith("+I[+I,");
         }
 
-        // 2. Test scan.startup.mode='latest' - should only read new records 
after subscription
-        String optionsLatest = " /*+ OPTIONS('scan.startup.mode' = 'latest') 
*/";
-        String queryLatest =
-                "SELECT _change_type, id, name FROM 
startup_mode_test$changelog" + optionsLatest;
-        CloseableIterator<Row> rowIterLatest = 
tEnv.executeSql(queryLatest).collect();
-
-        // Write new data after subscribing with 'latest'
-        CLOCK.advanceTime(Duration.ofMillis(100));
-        writeRows(conn, tablePath, Arrays.asList(row(6, "v6")), false);
-        List<String> latestResults = collectRowsWithTimeout(rowIterLatest, 1, 
true);
-        assertThat(latestResults).hasSize(1);
-        assertThat(latestResults.get(0)).isEqualTo("+I[+I, 6, v6]");
-
-        // 3. Test scan.startup.mode='timestamp' - should read records from 
specific timestamp
+        // 2. Test scan.startup.mode='timestamp' - should read records from 
specific timestamp
         // read between batch1 and batch2
         String optionsTimestamp =
                 " /*+ OPTIONS('scan.startup.mode' = 'timestamp', 
'scan.startup.timestamp' = '150') */";