[SPARK-24987][SS] - Fix Kafka consumer leak when no new offsets for TopicPartition#21997

Closed

YuvalItzchakov wants to merge 6 commits intoapache:masterfrom

YuvalItzchakov:master

Commits on Aug 26, 2017

Avoid using "return" inside `CachedKafkaConsumer.get` as it is passed to `org.apache.spark.util.UninterruptibleThread.runUninterruptibly` as a function type which causes a NonLocalReturnControl to …
Yuval Itzchakov
committed

Commits on Aug 27, 2017

Comments after code review
Yuval Itzchakov
committed

Commits on Aug 2, 2018

Merge remote-tracking branch 'upstream/master'
Yuval Itzchakov
committed

Commits on Aug 4, 2018

Merge remote-tracking branch 'origin/master'
Yuval Itzchakov
committed
Fixes SPARK-24987. Kafka consumer wasn't released when `fromOffset` was equal to `toOffset`.
Yuval Itzchakov
committed
Merge remote-tracking branch 'upstream/master'
Yuval Itzchakov
committed