You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2023/07/06 05:09:11 UTC
[beam] branch nightly-refs/heads/master updated (e8d8043f441 -> 79fcfc6fcb5)
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 e8d8043f441 Upgrade obsolete Avro plugin to 0.16.0 (#27232)
add 2c30acfe75b Consider beam_services option when determining the expansion service type
add c47438802d9 Merge pull request #27345: Consider beam_services option when determining the expansion service type
add 4d38d953788 updated go precommit with new condition, re-run action, pull_req_targ… (#27321)
add e00e19c0887 adds GitHub CLI to runner image (#27342)
add 619e41c7c0a Bump github.com/proullon/ramsql in /sdks (#27337)
add 54adbcb0b9c Bump actions/setup-python from 3 to 4 (#27336)
add 8b8fdcaf71c Verify script improvements (#27309)
add 3457434de74 fix repo and add paths to push trigger (#27357)
add 4a7a2579c70 Update Storage Write API Autosharding documentation (#27316)
add dc5bdb0d1e0 Bump golang.org/x/text from 0.10.0 to 0.11.0 in /sdks (#27351)
add a4141189b83 Updates PythonExternalTransform to support IPv6 addresses
add aa6f0a364db Merge pull request #27332: Updates PythonExternalTransform to support IPv6 addresses
add 35bdebc4c1b wrong path fix (#27359)
add 1842dd2f07a Respect BigQuery insert byte size limits (#24979)
add 0ce0d9acead Keep roles for gcp SA updated (#27306)
add cb8adf123e7 adding glcoud cli and kubectl (#27358)
add 2a1276544f6 Add Windmill support for MultimapState (#23492)
add 24fa67f958b Fix windmill proto (#27361)
add 9a11e28ce79 Use DOCKERHUB_USER instead of username (#27362)
add 15a54a00ac0 [Go SDK][Prism] Improve failed pipeline handling (#27297)
add 79fcfc6fcb5 Fix flakiness for BeamFnLoggingClientTest (#27308)
No new revisions were added by this update.
Summary of changes:
.github/actions/rerun-job-action/action.yml | 7 +
.../arc/images/Dockerfile | 14 +-
.github/workflows/beam_PreCommit_Go.yml | 78 +-
.github/workflows/build_release_candidate.yml | 4 +-
.github/workflows/build_runner_image.yml | 15 +-
CI.md | 3 +
release/src/main/scripts/mass_comment.py | 2 +-
release/src/main/scripts/verify_release_build.sh | 12 +-
.../beam/runners/dataflow/DataflowRunner.java | 11 +-
.../dataflow/worker/WindmillStateInternals.java | 674 ++++++++++-
.../dataflow/worker/WindmillStateReader.java | 319 ++++-
.../worker/WindmillStateInternalsTest.java | 1225 ++++++++++++++++++++
.../dataflow/worker/WindmillStateReaderTest.java | 723 +++++++++++-
.../worker/windmill/src/main/proto/windmill.proto | 82 +-
sdks/go.mod | 4 +-
sdks/go.sum | 8 +-
.../beam/runners/prism/internal/execute_test.go | 14 +
.../beam/runners/prism/internal/jobservices/job.go | 7 +-
.../prism/internal/jobservices/management.go | 17 +-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 12 +-
.../pkg/beam/runners/prism/internal/testdofns.go | 5 +
.../beam/runners/prism/internal/testdofns_test.go | 1 +
.../beam/runners/prism/internal/worker/bundle.go | 7 +
.../beam/runners/prism/internal/worker/worker.go | 26 +-
.../extensions/python/PythonExternalTransform.java | 11 +-
.../harness/logging/BeamFnLoggingClientTest.java | 50 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 2 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 74 +-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 32 +
sdks/python/apache_beam/transforms/external.py | 8 +
sdks/python/apache_beam/utils/subprocess_server.py | 7 +-
.../documentation/io/built-in/google-bigquery.md | 11 +-
32 files changed, 3339 insertions(+), 126 deletions(-)