SPARK-51252 Fix ClientStreamingQuerySuite

zecookiez · Feb 21, 2025 · fee7776 · fee7776
1 parent a5573ae
commit fee7776
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...jvm/src/test/scala/org/apache/spark/sql/connect/streaming/ClientStreamingQuerySuite.scala b/...jvm/src/test/scala/org/apache/spark/sql/connect/streaming/ClientStreamingQuerySuite.scala
@@ -56,7 +56,8 @@ class ClientStreamingQuerySuite extends QueryTest with RemoteSparkSession with L
   test("Streaming API with windowed aggregate query") {
     // This verifies standard streaming API by starting a streaming query with windowed count.
     withSQLConf(
-      "spark.sql.shuffle.partitions" -> "1" // Avoid too many reducers.
+      "spark.sql.shuffle.partitions" -> "1", // Avoid too many reducers.
+      "spark.sql.streaming.stateStore.numStateStoreInstanceMetricsToReport" -> "0"
     ) {
       val readDF = spark.readStream
         .format("rate")