You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@spark.apache.org by ka...@apache.org on 2024/07/30 23:04:24 UTC

(spark) branch master updated (acb2fecb8c17 -> 40d94b64e658)

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 acb2fecb8c17 [SPARK-49059][CONNECT] Move `SessionHolder.forTesting(...)` to the test package
     add 40d94b64e658 [SPARK-49031] Implement validation for the TransformWithStateExec operator using OperatorStateMetadataV2

No new revisions were added by this update.

Summary of changes:
 .../src/main/resources/error/error-conditions.json |  18 ++
 .../execution/streaming/IncrementalExecution.scala |  23 +-
 .../streaming/StatefulProcessorHandleImpl.scala    |  36 ++-
 .../streaming/TransformWithStateExec.scala         |  40 +++-
 .../TransformWithStateVariableUtils.scala          | 149 ++++++++++++
 .../streaming/state/StateStoreErrors.scala         |  43 ++++
 .../execution/streaming/statefulOperators.scala    |   4 +
 .../sql/streaming/TransformWithStateSuite.scala    | 258 ++++++++++++++++++++-
 8 files changed, 553 insertions(+), 18 deletions(-)
 create mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TransformWithStateVariableUtils.scala


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org