This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from c8d7ca02867 Fix DinD Action failure (#36813)
add 57320861aa2 Ensure that Operations are aborted when MapTaskExecutor is
closed. Add tests around setup/teardown of DoFns (#36631)
add 715a482bf5a Update REVIEWERS.yml (#36828)
add 3af78a7a19d Fix DinD startup failures (#36835)
add d4f5372a67c Improve error message for decoding input stream (#36823)
add ce58563ffd9 update container tag (#36826)
add 53a0d3c31b7 Update BOM to 26.71.0 (#36663)
add 3721c17265e Adds proto fields for overwriting fetch/write state
functionality (#36708)
add 914c16eb1d1 Provide more contextual error message for PyCoder (#36825)
No new revisions were added by this update.
Summary of changes:
.github/REVIEWERS.yml | 7 +-
.github/actions/dind-up-action/action.yml | 12 +-
...it_Java_ValidatesRunner_Dataflow_Streaming.json | 3 +-
...ostCommit_Java_ValidatesRunner_Dataflow_V2.json | 3 +-
.../workflows/beam_PreCommit_Python_Coverage.yml | 2 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 14 +--
examples/java/build.gradle | 1 +
.../beam/model/fn_execution/v1/beam_fn_api.proto | 9 ++
runners/google-cloud-dataflow-java/build.gradle | 30 ++++-
.../worker/IntrinsicMapTaskExecutorFactory.java | 53 +++++---
.../worker/util/common/worker/MapTaskExecutor.java | 71 ++++++++---
.../work/processing/StreamingWorkScheduler.java | 13 +-
.../IntrinsicMapTaskExecutorFactoryTest.java | 137 +++++++++++++++++++--
.../runners/dataflow/worker/SimpleParDoFnTest.java | 12 +-
.../worker/StreamingDataflowWorkerTest.java | 114 ++++++++++++++++-
.../worker/testing/TestCountingSource.java | 5 +
.../util/common/worker/MapTaskExecutorTest.java | 39 ++++++
.../container/license_scripts/dep_urls_java.yaml | 2 +-
.../gcp/bigquery/BeamRowToStorageApiProtoTest.java | 5 +-
sdks/python/apache_beam/coders/coder_impl.py | 17 ++-
.../apache_beam/runners/dataflow/internal/names.py | 3 +-
.../apache_beam/runners/worker/bundle_processor.py | 6 +-
settings.gradle.kts | 1 -
23 files changed, 471 insertions(+), 88 deletions(-)
