[beam] branch nightly-refs/heads/master updated (0c9cf43a7ed -> aea7c135a8e)

[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 0c9cf43a7ed [BEAM-13015] Only create a TimerBundleTracker if there are timers. (#17445)
     add 3cddfaf58c6 Add clarification on Filter transform's input function to pydoc. (#17704)
     add 1dfab628d03 [BEAM-14367]Flaky timeout in StatefulDoFnOnDirectRunnerTest.test_dynamic_timer_clear_then_set_timer (#17569)
     add ebb1a660674 [BEAM-14494] Tag rc dockre container with format ${RELEASE}rc${RC_NUM} (#17725)
     add ac24771d563 [BEAM-11578] Fix TypeError in dataflow_metrics has 0 distribution sum (#17706)
     add 3f05429e3ea [BEAM-14499] Step global, unbounded side input case back to warning (#17735)
     add e4a3bdd26d3 [BEAM-14484] Step back unexpected primary handling to warnings (#17724)
     add aea7c135a8e [BEAM-14486] Document pubsubio & fix its behavior. (#17709)

No new revisions were added by this update.

Summary of changes:
 .../src/main/scripts/build_release_candidate.sh    |   2 +-
 sdks/go/pkg/beam/core/runtime/exec/datasource.go   |  43 +-------
 .../pkg/beam/core/runtime/exec/datasource_test.go  |  75 ++-----------
 sdks/go/pkg/beam/core/runtime/exec/sdf.go          |  27 +++++
 sdks/go/pkg/beam/core/runtime/exec/sdf_test.go     | 119 +++++++++++++++++++++
 sdks/go/pkg/beam/core/sdf/sdf.go                   |  12 ++-
 sdks/go/pkg/beam/io/pubsubio/pubsubio.go           |  59 ++++++++--
 sdks/go/pkg/beam/pardo.go                          |   5 +-
 sdks/go/pkg/beam/pardo_test.go                     |  11 +-
 .../runners/dataflow/dataflow_metrics.py           |   2 +-
 sdks/python/apache_beam/transforms/core.py         |   3 +
 .../apache_beam/transforms/userstate_test.py       |   1 +
 12 files changed, 227 insertions(+), 132 deletions(-)