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 9d414bd53e30 [SPARK-54942][PYTHON][TESTS][FOLLOWUP] Add tests for
pa.Array.cast of nested/container types
add 9c91dace9b20 [SPARK-55111][SS] Unfinished repartitioning detection on
query restart
No new revisions were added by this update.
Summary of changes:
.../src/main/resources/error/error-conditions.json | 7 +++
.../spark/sql/errors/QueryExecutionErrors.scala | 9 +++
.../org/apache/spark/sql/internal/SQLConf.scala | 13 ++++
.../AsyncProgressTrackingMicroBatchExecution.scala | 10 ++-
.../streaming/runtime/MicroBatchExecution.scala | 20 +++++-
.../state/OfflineStateRepartitionRunner.scala | 51 +---------------
.../state/OfflineStateRepartitionUtils.scala | 67 ++++++++++++++++++++
.../streaming/MicroBatchExecutionSuite.scala | 71 +++++++++++++++++++---
.../state/OfflineStateRepartitionSuite.scala | 4 +-
9 files changed, 191 insertions(+), 61 deletions(-)
create mode 100644
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/OfflineStateRepartitionUtils.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
