This is an automated email from the ASF dual-hosted git repository.
hvanhovell pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from be04ac1ace9 [SPARK-44834][PYTHON][SQL][TESTS] Add SQL query tests for
Python UDTFs
add 6771d9d757f [SPARK-44433][3.5X] Terminate foreach batch runner when
streaming query terminates
No new revisions were added by this update.
Summary of changes:
.../sql/connect/planner/SparkConnectPlanner.scala | 37 +++++--
.../planner/StreamingForeachBatchHelper.scala | 109 ++++++++++++++++++---
.../spark/sql/connect/service/SessionHolder.scala | 9 +-
.../service/SparkConnectStreamingQueryCache.scala | 21 ++--
.../planner/StreamingForeachBatchHelperSuite.scala | 80 +++++++++++++++
.../spark/api/python/PythonWorkerFactory.scala | 2 +-
.../spark/api/python/StreamingPythonRunner.scala | 9 +-
7 files changed, 231 insertions(+), 36 deletions(-)
create mode 100644
connector/connect/server/src/test/scala/org/apache/spark/sql/connect/planner/StreamingForeachBatchHelperSuite.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
