Github user daroo closed the pull request at:
https://github.com/apache/spark/pull/19789
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
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](
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
Github user daroo commented on a diff in the pull request:
https://github.com/apache/spark/pull/19789#discussion_r152060617
--- Diff:
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/CachedKafkaConsumer.scala
---
@@ -155,11 +178,11 @@ object CachedKafkaConsum
Github user koeninger commented on a diff in the pull request:
https://github.com/apache/spark/pull/19789#discussion_r152056775
--- Diff:
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/CachedKafkaConsumer.scala
---
@@ -155,11 +178,11 @@ object CachedKafkaCo
GitHub user daroo opened a pull request:
https://github.com/apache/spark/pull/19789
[SPARK-22562][Streaming] CachedKafkaConsumer unsafe eviction from cache
## What changes were proposed in this pull request?
Fixes a problem when one thread wants to add a new consumer into fully
