LuciferYang commented on code in PR #41590:
URL: https://github.com/apache/spark/pull/41590#discussion_r1232968372
##########
connector/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSinkSuite.scala:
##########
@@ -287,12 +286,13 @@ abstract class KafkaSinkStreamingSuiteBase extends
KafkaSinkSuiteBase {
class KafkaSinkMicroBatchStreamingSuite extends KafkaSinkStreamingSuiteBase {
import testImplicits._
- override val streamingTimeout = 30.seconds
+ override val streamingTimeout = 10.milliseconds
override protected def createMemoryStream(): MemoryStreamBase[String] =
MemoryStream[String]
override protected def verifyResult(writer: StreamingQuery)(verifyFn: =>
Unit): Unit = {
failAfter(streamingTimeout) {
+ Thread.sleep(20)
Review Comment:
@zhengruifeng
Expected several cases will failure due to TestFailedDueToTimeoutException,
will revert this after check
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
