[GitHub] [spark] zsxwing commented on a change in pull request #25237: [SPARK-28489][SS] Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets

2019-07-25 Thread GitBox
zsxwing commented on a change in pull request #25237: [SPARK-28489][SS] Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets URL: https://github.com/apache/spark/pull/25237#discussion_r307544167 ## File path: external/kafka-0-10-sql/src/main/scala/org/apache/spark/s

[GitHub] [spark] zsxwing commented on a change in pull request #25237: [SPARK-28489][SS] Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets

2019-07-24 Thread GitBox
zsxwing commented on a change in pull request #25237: [SPARK-28489][SS] Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets URL: https://github.com/apache/spark/pull/25237#discussion_r306992273 ## File path: external/kafka-0-10-sql/src/main/scala/org/apache/spark/s

[GitHub] [spark] zsxwing commented on a change in pull request #25237: [SPARK-28489][SS]Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets

2019-07-23 Thread GitBox
zsxwing commented on a change in pull request #25237: [SPARK-28489][SS]Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets URL: https://github.com/apache/spark/pull/25237#discussion_r306583646 ## File path: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sq

[GitHub] [spark] zsxwing commented on a change in pull request #25237: [SPARK-28489][SS]Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets

2019-07-23 Thread GitBox
zsxwing commented on a change in pull request #25237: [SPARK-28489][SS]Fix a bug that KafkaOffsetRangeCalculator.getRanges may drop offsets URL: https://github.com/apache/spark/pull/25237#discussion_r306583463 ## File path: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sq