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 fcbb0340800 Bump go.opentelemetry.io/otel/sdk from 1.38.0 to 1.40.0 in
/sdks (#37730)
add e761581b30d Reduce Fn Runner changes
add 4739405cdbc Merge pull request #37727: [Drain] Reduce Fn Runner changes
add 1430241b6fe Pin aircompressor. (#37737)
add 3197d88ef5c Update java containers. (#37733)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 1 +
...TimeBoundedSplittableProcessElementInvoker.java | 21 ++++-
.../org/apache/beam/runners/core/ReduceFn.java | 3 +
.../beam/runners/core/ReduceFnContextFactory.java | 38 +++++++--
.../apache/beam/runners/core/ReduceFnRunner.java | 52 ++++++++----
.../core/SplittableParDoViaKeyedWorkItems.java | 1 +
.../apache/beam/runners/core/WindowMatchers.java | 52 ++++++++++--
runners/google-cloud-dataflow-java/build.gradle | 4 +-
.../windmill/state/WindmillTagEncodingV1.java | 5 +-
.../windmill/state/WindmillTagEncodingV2.java | 4 +-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 95 +++++++++++++++++++++-
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 9 +-
.../windmill/state/WindmillTagEncodingV2Test.java | 8 +-
sdks/java/core/build.gradle | 2 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 5 +-
.../org/apache/beam/sdk/transforms/DoFnTester.java | 20 ++++-
.../beam/sdk/values/ValueInSingleWindow.java | 20 +++--
17 files changed, 284 insertions(+), 56 deletions(-)
