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 2025/08/12 04:06:41 UTC
(beam) branch nightly-refs/heads/master updated (7299b2525bf -> 112791da919)
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 7299b2525bf Adds support for updating Schema state fields. (#35229)
add a0abcbe76b0 Install yarn via APT (#35840)
add bdf7912cd89 docs: update CHANGES.md with BigQueryIO bugfix (#35827)
add 14f887037d8 fix commons-lang3 vulnerability (#35824)
add 932f078e340 [Java Dataflow Streaming] Add support to AbstractWindmillStream to transition between physical streams within the same logical stream (#35523)
add ea8e08ba561 Secret management service (#35524)
add ddaae131603 Fix API doc index page broken format and link (#35845)
add 112791da919 feature added for the duration/timeout in test_pipeline (#35831)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
infra/keys/README.md | 93 +++
.../kustomization.yaml => infra/keys/config.yaml | 34 +-
infra/keys/gcp_logger.py | 153 ++++
infra/keys/keys.py | 390 ++++++++++
.../redis-values.yaml => infra/keys/keys.yaml | 24 +-
infra/{iam => keys}/requirements.txt | 7 +-
infra/keys/secret_manager.py | 787 +++++++++++++++++++
infra/keys/service_account.py | 425 +++++++++++
infra/keys/test_secret_manager.py | 839 +++++++++++++++++++++
infra/keys/test_service_account.py | 601 +++++++++++++++
.../windmill/client/AbstractWindmillStream.java | 314 +++++---
.../worker/windmill/client/WindmillStream.java | 4 -
.../windmill/client/grpc/GrpcCommitWorkStream.java | 40 +-
.../client/grpc/GrpcDirectGetWorkStream.java | 25 +-
.../windmill/client/grpc/GrpcGetDataStream.java | 51 +-
.../windmill/client/grpc/GrpcGetWorkStream.java | 25 +-
.../client/grpc/GrpcGetWorkerMetadataStream.java | 27 +-
.../client/grpc/GrpcWindmillStreamFactory.java | 108 ++-
.../dataflow/worker/FakeWindmillServer.java | 6 +-
.../worker/StreamingDataflowWorkerTest.java | 10 +-
.../client/AbstractWindmillStreamTest.java | 26 +-
.../client/TriggeredScheduledExecutorService.java | 140 ++++
.../client/grpc/FakeWindmillGrpcService.java | 47 +-
.../client/grpc/GrpcCommitWorkStreamTest.java | 674 +++++++++++++++++
.../client/grpc/GrpcGetDataStreamTest.java | 831 +++++++++++++++++++-
sdks/java/javadoc/overview.html | 4 -
sdks/python/apache_beam/ml/anomaly/transforms.py | 12 +-
sdks/python/apache_beam/testing/test_pipeline.py | 9 +-
website/Dockerfile | 19 +-
.../www/site/content/en/get-started/downloads.md | 3 -
32 files changed, 5470 insertions(+), 262 deletions(-)
create mode 100644 infra/keys/README.md
copy .test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/echo-10-per-1s-quota/kustomization.yaml => infra/keys/config.yaml (50%)
create mode 100644 infra/keys/gcp_logger.py
create mode 100644 infra/keys/keys.py
copy .test-infra/mock-apis/infrastructure/kubernetes/redis/redis-values.yaml => infra/keys/keys.yaml (52%)
copy infra/{iam => keys}/requirements.txt (88%)
create mode 100644 infra/keys/secret_manager.py
create mode 100644 infra/keys/service_account.py
create mode 100644 infra/keys/test_secret_manager.py
create mode 100644 infra/keys/test_service_account.py
create mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/TriggeredScheduledExecutorService.java