This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 61a884e (commit)
to b8e390a (commit)
from 61a884e Merge pull request #15182 from pcoet/website-docs
add 09d4fab Default to Runner v2 for Python Streaming jobs. (#15140)
add 31c2b76 Moving to 2.33.0-SNAPSHOT on master branch.
add e8f9ad9 [BEAM-12548] Fix malformed comment for EqualsFloat (#15200)
add bbe7b64 [BEAM-4152] Implement session window merging in the Go direct
runner (#15196)
add f88ed4e [BEAM-12643] Resolved the concurrent writes issue for
parallel tests (#15199)
add 63257ed [BEAM-10212] Add caching state client wrapper (#15170)
add 2d7c4a8 [BEAM-12625] Annotate
testTwoTimersSettingEachOtherWithCreateAsInputUnbounded.
add b8e390a Merge pull request #15205 from ibzib/BEAM-12625
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
gradle.properties | 4 +-
sdks/go/pkg/beam/core/core.go | 2 +-
sdks/go/pkg/beam/core/util/hooks/hooks.go | 124 ++++++--
sdks/go/pkg/beam/core/util/hooks/hooks_test.go | 60 +++-
sdks/go/pkg/beam/runners/direct/gbk.go | 109 ++++++-
sdks/go/pkg/beam/runners/direct/gbk_test.go | 88 ++++++
sdks/go/pkg/beam/testing/passert/floats.go | 2 +-
sdks/go/test/integration/integration.go | 2 -
.../org/apache/beam/sdk/transforms/ParDoTest.java | 7 +-
.../fn/harness/state/CachingBeamFnStateClient.java | 178 +++++++++++
.../state/CachingBeamFnStateClientTest.java | 335 +++++++++++++++++++++
.../fn/harness/state/FakeBeamFnStateClient.java | 4 +
.../runners/dataflow/dataflow_runner.py | 8 +-
.../runners/dataflow/dataflow_runner_test.py | 11 +-
sdks/python/apache_beam/version.py | 2 +-
16 files changed, 872 insertions(+), 66 deletions(-)
create mode 100644 sdks/go/pkg/beam/runners/direct/gbk_test.go
create mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/CachingBeamFnStateClient.java
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/state/CachingBeamFnStateClientTest.java
