This is an automated email from the ASF dual-hosted git repository.
Amar3tto pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 720326829a7 Fill gaps between GcsUtilV2 and GcsUtilV1 (#40244)
add 1e7255931d8 Fix stale ExecutorClassLoader leak and local JAR staging
in portable Spark runner
new 13a3083968f Merge pull request #40270 from Abacn/fix-spark-staging
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
..._PostCommit_Java_PVR_Spark4_StructuredStreaming.json | 3 ++-
.../apache/beam/runners/jobsubmission/JobInvoker.java | 15 ++++++++++++++-
.../beam/runners/spark/SparkCommonPipelineOptions.java | 7 ++++++-
.../apache/beam/runners/spark/SparkPipelineRunner.java | 8 ++++++++
.../runners/spark/translation/SparkContextFactory.java | 12 ++++++++++--
.../beam/runners/spark/SparkPipelineOptionsTest.java | 17 +++++++++++++++++
6 files changed, 57 insertions(+), 5 deletions(-)
