-
- Downloads
[SPARK-17782][STREAMING][KAFKA] alternative eliminate race condition of poll twice
## What changes were proposed in this pull request? Alternative approach to https://github.com/apache/spark/pull/15387 Author: cody koeninger <cody@koeninger.org> Closes #15401 from koeninger/SPARK-17782-alt.
Showing
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/ConsumerStrategy.scala 4 additions, 0 deletions...rg/apache/spark/streaming/kafka010/ConsumerStrategy.scala
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/DirectKafkaInputDStream.scala 21 additions, 2 deletions...he/spark/streaming/kafka010/DirectKafkaInputDStream.scala
- external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/DirectKafkaStreamSuite.scala 7 additions, 5 deletions...che/spark/streaming/kafka010/DirectKafkaStreamSuite.scala
Loading
Please register or sign in to comment