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/08/08 04:41:49 UTC
[beam] branch nightly-refs/heads/master updated (9ca6c334915 -> 29ea352fa7c)
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 9ca6c334915 Fix broken url for 'Tour of Beam' (#27412)
add 03f8830dfab Bump golang.org/x/oauth2 from 0.10.0 to 0.11.0 in /sdks (#27870)
add 4bae68c08c1 [AWS] Adjust interface of SqsIO.writeBatches to make entryMapper optional. (#27800)
add 73e015be45a Update versions based on libraries-bom, and add comment to keep consistency (#27865)
add ee97da5c7af Ensure that if grpc stream terminates that DirectStreamObserver does not block on Phaser. (#26631)
add 347f84c666e Fix action run on base branch (#27860)
add 23d44a45d68 Fix routing header issue in Firestore Beam connector (#27858)
add 3b112e8bd8d [#24789] Remainder of changes from #27550. (#27822)
add d227b8139f1 Bump beam-master legacy container to beam-master-20230807 (#27881)
add 450d801c888 Update example for BundleProcessResponse (#27834)
add 95a56976bae Move code contribution guide into repo (#27883)
add 29ea352fa7c Add an option to the FnApi harness PIPELINE_OPTIONS_FILE that overrides the old PIPELINE_OPTIONS environment variable with the contents of a file. This allows us to circumvent kernel limits on the combined size of environment variables and commandline arguments. (#27841)
No new revisions were added by this update.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 2 +-
.github/actions/setup-action/action.yml | 14 +-
.../beam_PreCommit_Java_Flink_Versions.yml | 2 +-
CONTRIBUTING.md | 309 ++++++++++++++++-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 9 +-
.../beam/model/fn_execution/v1/beam_fn_api.proto | 65 ++--
runners/google-cloud-dataflow-java/build.gradle | 2 +-
sdks/go.mod | 10 +-
sdks/go.sum | 20 +-
sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 12 +-
sdks/go/pkg/beam/core/runtime/harness/harness.go | 2 +-
sdks/go/pkg/beam/core/runtime/harness/statemgr.go | 9 +-
sdks/go/pkg/beam/core/runtime/symbols.go | 2 +-
sdks/go/pkg/beam/create.go | 5 +
sdks/go/pkg/beam/create_test.go | 4 +-
sdks/go/pkg/beam/io/databaseio/database_test.go | 1 +
sdks/go/pkg/beam/io/datastoreio/datastore_test.go | 5 +
sdks/go/pkg/beam/pardo_test.go | 4 +-
.../prism/internal/engine/elementmanager.go | 1 -
.../beam/runners/prism/internal/handlerunner.go | 2 +-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 8 +-
.../runners/prism/internal/unimplemented_test.go | 1 -
.../beam/runners/prism/internal/worker/bundle.go | 2 +
.../beam/runners/prism/internal/worker/worker.go | 7 +-
.../go/pkg/beam/runners/universal/runnerlib/job.go | 16 +-
sdks/go/pkg/beam/runners/vet/vet.go | 2 +-
sdks/go/test/integration/integration.go | 3 +-
.../beam/sdk/fn/stream/DirectStreamObserver.java | 10 +-
.../stream/ForwardingClientResponseObserver.java | 17 +-
.../sdk/fn/stream/OutboundObserverFactory.java | 8 +-
.../sdk/fn/stream/DirectStreamObserverTest.java | 92 ++++++
.../ForwardingClientResponseObserverTest.java | 46 ++-
.../java/org/apache/beam/fn/harness/FnHarness.java | 32 +-
.../org/apache/beam/sdk/io/aws2/sqs/SqsIO.java | 187 ++++++++---
.../sdk/io/aws2/sqs/SqsIOWriteBatchesTest.java | 141 +++++++-
.../beam/sdk/io/aws2/sqs/SqsIOWriteTest.java | 68 ----
.../beam/sdk/io/aws2/sqs/testing/SqsIOIT.java | 4 +-
sdks/java/io/google-cloud-platform/build.gradle | 4 -
.../FirestoreStatefulComponentFactory.java | 26 +-
website/www/site/content/en/contribute/_index.md | 8 +-
.../en/contribute/get-started-contributing.md | 367 +--------------------
.../content/en/documentation/programming-guide.md | 9 +-
.../partials/section-menu/en/contribute.html | 2 +-
43 files changed, 929 insertions(+), 611 deletions(-)
delete mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sqs/SqsIOWriteTest.java