This is an automated email from the ASF dual-hosted git repository.
ashrigondekar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 4435a3a7f088 [SPARK-54558][SQL] Fix Internal Exception when Exception
Handlers with no BEGIN/END are used
add 250ccca3f2b5 [SPARK-54423][SS] Introducing OffsetMap to enable Named
Streaming Sources
No new revisions were added by this update.
Summary of changes:
.../sql/kafka010/KafkaMicroBatchSourceSuite.scala | 4 +-
.../datasources/v2/state/StateDataSource.scala | 2 +-
.../checkpointing/AsyncOffsetSeqLog.scala | 2 +-
.../streaming/checkpointing/OffsetSeq.scala | 85 +++++++++++++++----
.../streaming/checkpointing/OffsetSeqLog.scala | 95 +++++++++++++++++-----
.../streaming/continuous/ContinuousExecution.scala | 9 +-
.../runtime/AcceptsLatestSeenOffsetHandler.scala | 9 +-
.../AsyncProgressTrackingMicroBatchExecution.scala | 15 ++--
.../streaming/runtime/MicroBatchExecution.scala | 36 +++++---
.../streaming/runtime/StreamExecution.scala | 12 ++-
.../streaming/runtime/StreamProgress.scala | 38 ++++++++-
.../state/OfflineStateRepartitionRunner.scala | 9 +-
.../resources/structured-streaming/offset-map/0 | 3 +
.../resources/structured-streaming/offset-map/1 | 3 +
.../resources/structured-streaming/offset-map/2 | 3 +
.../resources/structured-streaming/offset-map/3 | 3 +
...cProgressTrackingMicroBatchExecutionSuite.scala | 4 +-
.../execution/streaming/OffsetSeqLogSuite.scala | 30 +++++--
.../state/OfflineStateRepartitionSuite.scala | 4 +-
19 files changed, 284 insertions(+), 82 deletions(-)
create mode 100644
sql/core/src/test/resources/structured-streaming/offset-map/0
create mode 100644
sql/core/src/test/resources/structured-streaming/offset-map/1
create mode 100644
sql/core/src/test/resources/structured-streaming/offset-map/2
create mode 100644
sql/core/src/test/resources/structured-streaming/offset-map/3
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
