Github user dilipbiswal commented on a diff in the pull request:
https://github.com/apache/spark/pull/22671#discussion_r223819177
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSinkSuite.scala
---
@@ -332,7 +332,9 @@ class KafkaSinkSuite extends StreamTest with
SharedSQLContext with KafkaTest {
var ex: Exception = null
try {
ex = intercept[StreamingQueryException] {
- writer = createKafkaWriter(input.toDF(), withTopic = Some(topic))()
+ writer = createKafkaWriter(input.toDF(),
--- End diff --
@srowen I have used 5 sec timeout for now and i have moved it to
createKafkaWriter per ur suggestion. Pl.. let me know if you are okay.
Currently there is only one test that make uses of this timeout value. So keep
it conservatively at 5 secs ?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
