(fluss) branch main updated: [spark] Fix unstable UT caused by CheckLastBatch call (#2628)

[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 139035e86 [spark] Fix unstable UT caused by CheckLastBatch call (#2628)
139035e86 is described below

commit 139035e861ff74d44c429e33ea9a36bd3659b9d3
Author: Yang Zhang <yangchuan...@alibaba-inc.com>
AuthorDate: Wed Feb 11 00:16:35 2026 +0800

    [spark] Fix unstable UT caused by CheckLastBatch call (#2628)
---
 .../src/test/scala/org/apache/fluss/spark/SparkStreamingTest.scala     | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/fluss-spark/fluss-spark-ut/src/test/scala/org/apache/fluss/spark/SparkStreamingTest.scala
 
b/fluss-spark/fluss-spark-ut/src/test/scala/org/apache/fluss/spark/SparkStreamingTest.scala
index d9816d6c1..6921952c7 100644
--- 
a/fluss-spark/fluss-spark-ut/src/test/scala/org/apache/fluss/spark/SparkStreamingTest.scala
+++ 
b/fluss-spark/fluss-spark-ut/src/test/scala/org/apache/fluss/spark/SparkStreamingTest.scala
@@ -164,7 +164,6 @@ class SparkStreamingTest extends FlussSparkTestBase with 
StreamTest {
         StartStream(),
         AddFlussData(tableName, schema, Seq(Row(4, "data4"), Row(5, "data5"))),
         ProcessAllAvailable(),
-        CheckLastBatch(Row(4, "data4"), Row(5, "data5")),
         CheckAnswer(Row(4, "data4"), Row(5, "data5"))
       )
 
@@ -206,7 +205,6 @@ class SparkStreamingTest extends FlussSparkTestBase with 
StreamTest {
         StartStream(),
         AddFlussData(tableName, schema, Seq(Row(4, "data4", "22"), Row(5, 
"data5", "11"))),
         ProcessAllAvailable(),
-        CheckLastBatch(Row(4, "data4", "22"), Row(5, "data5", "11")),
         CheckAnswer(Row(4, "data4", "22"), Row(5, "data5", "11"))
       )
 
@@ -254,7 +252,6 @@ class SparkStreamingTest extends FlussSparkTestBase with 
StreamTest {
         StartStream(),
         AddFlussData(tableName, schema, Seq(Row(4, "data4", 44, "dd"), Row(5, 
"data5", 55, "ee"))),
         ProcessAllAvailable(),
-        CheckLastBatch(Row(4, "data4", 44, "dd"), Row(5, "data5", 55, "ee")),
         CheckAnswer(Row(4, "data4", 44, "dd"), Row(5, "data5", 55, "ee"))
       )