Github user dilipbiswal commented on the issue:
https://github.com/apache/spark/pull/22670
@srowen Thanks. Did you mean, the test cases should extend a shared spark
context (SharedKafkaSparkContext) which would have this property set ?
Actually Sean, there are 3 suites in this directory.
`DirectKafkaStreamSuite.scala` `KafkaDataConsumerSuite.scala` and
`KafkaRDDSuite.scala`. Given only two tests which are affected by this timeout
(which we are fixing here), do you think we need to take on this refactoring
work as part of this PR ? Please let me know.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
