Github user daroo commented on a diff in the pull request:
https://github.com/apache/spark/pull/19789#discussion_r152951885
--- Diff:
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaRDD.scala
---
@@ -211,8 +211,8 @@ private[spark] class KafkaRDD[K, V](
var requestOffset = part.fromOffset
def closeIfNeeded(): Unit = {
- if (!useConsumerCache && consumer != null) {
- consumer.close
+ if (consumer != null) {
+ consumer.close()
--- End diff --
formatting changed
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
