fix unit test. (Have to change the error message to follow the existi…

…ng pattern

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationChecker.scala

@@ -522,9 +522,9 @@ object UnsupportedOperationChecker extends Logging {
             }
           }.mkString(", ")
           throw new AnalysisException(
-            s"Unsupported window function in $windowFuncs. Structured " +
-            "Streaming only supports time-window aggregation using the `window` function. " +
-            s"(window specification: '$windowSpec')",
+            s"Window function is not supported in $windowFuncs on streaming DataFrames/Datasets. " +
+            "Structured Streaming only supports time-window aggregation using the `window` " +
+            s"function. (window specification: '$windowSpec')",
             subPlan.origin.line,
             subPlan.origin.startPosition)
 

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationsSuite.scala

@@ -738,7 +738,10 @@ class UnsupportedOperationsSuite extends SparkFunSuite with SQLHelper {
   testUnaryOperatorInStreamingPlan(
     "sample", Sample(0.1, 1, true, 1L, _), expectedMsg = "sampling")
   testUnaryOperatorInStreamingPlan(
-    "window", Window(Nil, Nil, Nil, _), expectedMsg = "non-time-based windows")
+    "window",
+    Window(Nil, Nil, Nil, _),
+    expectedMsg =
+      "Structured Streaming only supports time-window aggregation using the `window` function")
 
   // Output modes with aggregation and non-aggregation plans
   testOutputMode(Append, shouldSupportAggregation = false, shouldSupportNonAggregation = true)

sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamSuite.scala

@@ -703,7 +703,7 @@ class StreamSuite extends StreamTest {
         .start()
     }
   assert(e.getMessage.contains(
-    "Unsupported window function in 'row_number()' as column 'rn_col'"))
+    "Window function is not supported in 'row_number()' as column 'rn_col'"))
   }