(paimon) branch master updated: [test][spark] Fix flaky timestamp-based streaming source test (#10634)

[lzljs3620320]

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

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 987dc7f68c [test][spark] Fix flaky timestamp-based streaming source 
test (#10634)
987dc7f68c is described below

commit 987dc7f68c3fc737ee53d34d3cd67b226953917d
Author: Zouxxyy <zouxinyu....@alibaba-inc.com>
AuthorDate: Sun Oct 18 08:45:38 2026 +0800

    [test][spark] Fix flaky timestamp-based streaming source test (#10634)
---
 .../src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala
 
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala
index cd6aa554f7..d49b0dbe73 100644
--- 
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala
+++ 
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala
@@ -432,8 +432,8 @@ class PaimonSourceTest extends PaimonSparkTestBase with 
StreamTest {
         val ts1 = System.currentTimeMillis()
         val TableSnapshotState(_, location, snapshotData, latestChanges, _) =
           prepareTableAndGetLocation(3, true)
-        // timestamp that is after this table is created and data is written.
-        val ts2 = System.currentTimeMillis()
+        // Streaming reads include snapshots at the start timestamp, so 
exclude the last snapshot.
+        val ts2 = 
loadTable("T").snapshotManager().latestSnapshot().timeMillis() + 1
 
         val query1 = spark.readStream
           .format("paimon")