[GitHub] [spark] srowen commented on a change in pull request #25583: [MINOR][SS] Reuse KafkaSourceInitialOffsetWriter to deduplicate

2019-08-26 Thread GitBox
srowen commented on a change in pull request #25583: [MINOR][SS] Reuse KafkaSourceInitialOffsetWriter to deduplicate URL: https://github.com/apache/spark/pull/25583#discussion_r317621710 ## File path: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceI

[GitHub] [spark] srowen commented on a change in pull request #25583: [MINOR][SS] Reuse KafkaSourceInitialOffsetWriter to deduplicate

2019-08-26 Thread GitBox
srowen commented on a change in pull request #25583: [MINOR][SS] Reuse KafkaSourceInitialOffsetWriter to deduplicate URL: https://github.com/apache/spark/pull/25583#discussion_r317621165 ## File path: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceI

[GitHub] [spark] srowen commented on a change in pull request #25583: [MINOR][SS] Reuse KafkaSourceInitialOffsetWriter to deduplicate

2019-08-26 Thread GitBox
srowen commented on a change in pull request #25583: [MINOR][SS] Reuse KafkaSourceInitialOffsetWriter to deduplicate URL: https://github.com/apache/spark/pull/25583#discussion_r317621622 ## File path: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceI