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