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