Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21497#discussion_r193292673
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/sources/TextSocketStreamSuite.scala
---
@@ -256,6 +246,66 @@ class TextSocketStreamSuite extends StreamTest with
SharedSQLContext with Before
}
}
+ test("verify ServerThread only accepts the first connection") {
+ serverThread = new ServerThread()
+ serverThread.start()
+
+ withSQLConf("spark.sql.streaming.unsupportedOperationCheck" ->
"false") {
--- End diff --
I would use `SQLConf.UNSUPPORTED_OPERATION_CHECK_ENABLED.key` BTW.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
