Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/17228#discussion_r105314130
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/CachedKafkaConsumer.scala
---
@@ -398,4 +386,23 @@ private[kafka010] object
Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/17228#discussion_r105313916
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/CachedKafkaConsumer.scala
---
@@ -398,4 +386,23 @@ private[kafka010] object
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/17228#discussion_r105312514
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/CachedKafkaConsumer.scala
---
@@ -398,4 +386,23 @@ private[kafka010] object
GitHub user brkyvz opened a pull request:
https://github.com/apache/spark/pull/17228
[SPARK-19886] Fix reportDataLoss if statement in SS KafkaSource
## What changes were proposed in this pull request?
You can merge this pull request into a Git repository by running:
$
