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