This is an automated email from the ASF dual-hosted git repository. jark pushed a commit to branch release-0.9 in repository https://gitbox.apache.org/repos/asf/fluss.git
commit 5816bd6de137896ead159fbc1d004ba4fdb81725 Author: Yang Zhang <[email protected]> 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")) )
