SPARK-51252 Clean up tests and fix code formatting

zecookiez · Feb 21, 2025 · e219d2b · e219d2b
1 parent fee7776
commit e219d2b
Show file tree

Hide file tree

Showing 2 changed files with 257 additions and 452 deletions.
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
@@ -57,8 +57,7 @@ class ClientStreamingQuerySuite extends QueryTest with RemoteSparkSession with L
     // 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.streaming.stateStore.numStateStoreInstanceMetricsToReport" -> "0"
-    ) {
+      "spark.sql.streaming.stateStore.numStateStoreInstanceMetricsToReport" -> "0") {
       val readDF = spark.readStream
         .format("rate")
         .option("rowsPerSecond", "10")