Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/19789#discussion_r152895550
--- 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 --
I think this should be double spaced
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
