[beam] branch nightly-refs/heads/master updated (e7d3e8c9814 -> 8d3b4bbaa94)

[gi...@apache.org]

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 e7d3e8c9814 [BEAM-14048] [CdapIO] Add ConfigWrapper for building CDAP PluginConfigs (#17051)
     add 09e3290fee4 [BEAM-14196] add test verifying output watermark propagation in bundle
     add 51e882c0309 [BEAM-14196] Fix FlinkRunner mid-bundle output watermark handling
     add 3ac86e46e82 Merge pull request #17504: [BEAM-14196] add test verifying output watermark propagation in bundle
     add 78ae512859b Move master readme.md to 2.40.0
     add 017f846ca34 Merge pull request #17552 from y1chi/update_md
     add 0af670d4616 [BEAM-14173] Fix Go Loadtests on Dataflow & partial fix for Flink (#17554)
     add 121597351d8 Upgrade python sdk container requirements. (#17549)
     add b6565b929bd Merge pull request #17497: [BEAM-11205] Update GCP Libraries BOM version to 25.2.0 and associated deps
     add 9154f8b3cf0 [BEAM-12603] Add retry on grpc data channel and remove retry from test. (#17537)
     add fa01615e520 Merge pull request #17359: [BEAM-14303] Add a way to exclude output timestamp watermark holds
     add 8db69a241c1 [BEAM-14347] Allow users to optimize DoFn execution with a single generic registration function (#17429)
     add 8d3b4bbaa94 [BEAM-5878] Add (failing) kwonly-argument test (#17509)

No new revisions were added by this update.

Summary of changes:
 .github/codecov.yml                                |    1 +
 .github/workflows/go_tests.yml                     |    6 +-
 .github/workflows/local_env_tests.yml              |    4 +-
 .github/workflows/python_tests.yml                 |    2 +-
 .test-infra/jenkins/README.md                      |    2 +-
 .../jenkins/job_LoadTests_Combine_Go.groovy        |    8 +
 .test-infra/jenkins/job_LoadTests_GBK_Go.groovy    |   16 +
 .test-infra/jenkins/job_LoadTests_ParDo_Go.groovy  |   10 +
 .../jenkins/job_LoadTests_SideInput_Go.groovy      |    6 +
 .test-infra/jenkins/job_LoadTests_coGBK_Go.groovy  |   10 +
 CHANGES.md                                         |   36 +-
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   28 +-
 playground/README.md                               |    2 +-
 .../apache/beam/runners/core/SimpleDoFnRunner.java |  170 +-
 .../beam/runners/core/SimpleDoFnRunnerTest.java    |   10 +-
 .../wrappers/streaming/DoFnOperator.java           |   46 +-
 .../streaming/ExecutableStageDoFnOperator.java     |   12 +-
 .../beam/runners/flink/FlinkSavepointTest.java     |    2 +-
 .../wrappers/streaming/DoFnOperatorTest.java       |   35 +-
 .../streaming/ExecutableStageDoFnOperatorTest.java |    3 +-
 .../wrappers/streaming/WindowDoFnOperatorTest.java |    9 +
 .../dataflow/worker/WindmillTimerInternals.java    |   10 +-
 sdks/go.mod                                        |   48 +-
 sdks/go/cmd/specialize/main.go                     |  106 +-
 sdks/go/cmd/specialize/main_test.go                |  107 +
 sdks/go/pkg/beam/io/synthetic/source.go            |   22 +-
 sdks/go/pkg/beam/registration/doc.go               |   30 +
 .../example_registration_test.go}                  |   39 +-
 sdks/go/pkg/beam/registration/registration.go      | 7054 ++++++++++++++++++++
 sdks/go/pkg/beam/registration/registration.tmpl    |  265 +
 sdks/go/pkg/beam/registration/registration_test.go |  214 +
 sdks/go/run_with_go_version.sh                     |    2 +-
 sdks/go/test/load/sideinput/sideinput.go           |    9 +-
 .../container/license_scripts/dep_urls_java.yaml   |    2 +-
 .../main/java/org/apache/beam/sdk/state/Timer.java |    6 +
 .../apache/beam/sdk/transforms/Deduplicate.java    |    8 +-
 .../org/apache/beam/sdk/transforms/ParDoTest.java  |  108 +-
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |   65 +-
 .../bigquery/StorageApiWritesShardedRecords.java   |   11 +-
 .../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java  |    1 +
 sdks/python/apache_beam/runners/common_test.py     |   19 +
 .../portability/fn_api_runner/fn_runner_test.py    |   53 -
 .../apache_beam/runners/worker/data_plane.py       |   25 +-
 .../apache_beam/runners/worker/sdk_worker.py       |   20 +-
 .../container/license_scripts/dep_urls_py.yaml     |    5 +
 .../manual_licenses/beautifulsoup4/LICENSE         |   30 +
 .../container/py37/base_image_requirements.txt     |   74 +-
 .../container/py38/base_image_requirements.txt     |   72 +-
 .../container/py39/base_image_requirements.txt     |   74 +-
 .../content/en/documentation/programming-guide.md  |    2 +-
 .../site/content/en/get-started/quickstart-go.md   |    2 +-
 51 files changed, 8481 insertions(+), 420 deletions(-)
 create mode 100644 sdks/go/cmd/specialize/main_test.go
 create mode 100644 sdks/go/pkg/beam/registration/doc.go
 copy sdks/go/pkg/beam/{core/runtime/exec/discard.go => registration/example_registration_test.go} (52%)
 create mode 100644 sdks/go/pkg/beam/registration/registration.go
 create mode 100644 sdks/go/pkg/beam/registration/registration.tmpl
 create mode 100644 sdks/go/pkg/beam/registration/registration_test.go
 create mode 100644 sdks/python/container/license_scripts/manual_licenses/beautifulsoup4/LICENSE