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/01 04:37:08 UTC
[beam] branch nightly-refs/heads/master updated (7890bdcee84 -> 753bae4d941)
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 7890bdcee84 Merge pull request #27277: Use requirements file as a constraint when building the expansion service container
add 09159ad46e2 [#27207] Simplify Go quickstart.
add 98886285a54 Merge pull request #27299: [#27207] Update Go quickstart.
add 4d22675b2bf Add flag to do a docker system prune between docker push steps (#26967)
add 2d9635c26c3 changed rerun logic to accomodate when job is not in check list (#27318)
add 30762dfc58a Populate getWorkStream latencies in dataflow streaming worker harness (#26085)
add 76e5fc502d4 Squash of two similar checks, not null check for "restriction.milisToRun" before unboxing the primitive (#27304)
add 33b3437f0a8 Publish Docker artifacts from build_release_candidate.yml (#26950)
add 6247318b3f3 Remove relative imports. (#27323)
add c36f0f13d35 Add topicPattern property to KafkaIO.Read to match topics using a regex (#26948)
add 34a17963d57 Replace StorageV1 client with GCS client (#25965)
add 753bae4d941 Update CHANGES.md after 2.49.0 cut (#27328)
No new revisions were added by this update.
Summary of changes:
.github/actions/rerun-job-action/action.yml | 15 +-
.github/workflows/build_release_candidate.yml | 45 +
CHANGES.md | 37 +-
build.gradle.kts | 53 +-
.../assets/symbols/python.g.yaml | 8 -
.../dataflow/worker/StreamingDataflowWorker.java | 55 +-
.../worker/windmill/GrpcWindmillServer.java | 169 +-
.../worker/windmill/WindmillServerStub.java | 7 +-
.../dataflow/worker/FakeWindmillServer.java | 13 +-
.../worker/StreamingDataflowWorkerTest.java | 121 +-
.../worker/windmill/GrpcWindmillServerTest.java | 63 +-
.../worker/windmill/src/main/proto/windmill.proto | 42 +-
.../beam/io/debezium/KafkaSourceConsumerFn.java | 8 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 71 +-
.../KafkaIOReadImplementationCompatibility.java | 1 +
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 30 +-
.../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 26 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 100 +
.../io/kafka/WatchForKafkaTopicPartitionsTest.java | 48 +-
.../examples/complete/game/user_score.py | 1 +
.../apache_beam/examples/snippets/snippets_test.py | 7 +-
sdks/python/apache_beam/internal/gcp/auth.py | 7 +-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 4 +-
sdks/python/apache_beam/io/gcp/gcsfilesystem.py | 33 +-
.../apache_beam/io/gcp/gcsfilesystem_test.py | 17 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 625 ++---
.../apache_beam/io/gcp/gcsio_integration_test.py | 149 +-
sdks/python/apache_beam/io/gcp/gcsio_overrides.py | 55 -
sdks/python/apache_beam/io/gcp/gcsio_test.py | 886 ++-----
.../io/gcp/internal/clients/storage/__init__.py | 33 -
.../internal/clients/storage/storage_v1_client.py | 1517 -----------
.../clients/storage/storage_v1_messages.py | 2714 --------------------
.../options/pipeline_options_validator_test.py | 1 +
.../runners/dataflow/internal/apiclient.py | 52 +-
.../apache_beam/runners/interactive/utils.py | 26 +-
.../apache_beam/runners/interactive/utils_test.py | 41 +-
.../runners/portability/sdk_container_builder.py | 41 +-
sdks/python/container/build.gradle | 30 +-
sdks/python/mypy.ini | 3 -
sdks/python/setup.py | 1 +
.../site/content/en/get-started/quickstart-go.md | 28 +-
41 files changed, 1324 insertions(+), 5859 deletions(-)
delete mode 100644 sdks/python/apache_beam/io/gcp/gcsio_overrides.py
delete mode 100644 sdks/python/apache_beam/io/gcp/internal/clients/storage/__init__.py
delete mode 100644 sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_client.py
delete mode 100644 sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_messages.py