This is an automated email from the ASF dual-hosted git repository. kabhwan pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/spark.git.
from 58d4da1 [SPARK-35486][CORE] TaskMemoryManager: retry if other task takes memory freed by partial self-spill add a57afd4 [SPARK-29223][SQL][SS] New option to specify timestamp on all subscribing topic-partitions in Kafka source No new revisions were added by this update. Summary of changes: docs/structured-streaming-kafka-integration.md | 63 ++++--- .../spark/sql/kafka010/KafkaContinuousStream.scala | 2 + .../spark/sql/kafka010/KafkaMicroBatchStream.scala | 2 + .../spark/sql/kafka010/KafkaOffsetRangeLimit.scala | 7 + .../spark/sql/kafka010/KafkaOffsetReader.scala | 14 ++ .../sql/kafka010/KafkaOffsetReaderAdmin.scala | 34 ++++ .../sql/kafka010/KafkaOffsetReaderConsumer.scala | 36 ++++ .../apache/spark/sql/kafka010/KafkaSource.scala | 2 + .../spark/sql/kafka010/KafkaSourceProvider.scala | 85 ++++++---- .../sql/kafka010/KafkaMicroBatchSourceSuite.scala | 181 +++++++++++++++++---- .../spark/sql/kafka010/KafkaRelationSuite.scala | 47 ++++++ 11 files changed, 394 insertions(+), 79 deletions(-) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org