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 587f58e (commit)
to b31a7ea (commit)
from 587f58e Add a timeout for BQ streaming_insert RPCS (#15541)
add ebf2aac Merge pull request #15537 from [BEAM-12908] Add a sleep to
the IT after topic creation to wait for propagation
add 531b29c Fix 2.32.0 release notes.
add 8e3c1de Merge pull request #15443 Fix 2.32.0 release notes
add 4c6a827 Add MapState and SetState support
add 20108fd Merge pull request #15238 from kileys/beam-12588-multimapstate
add 2606ae4 Merge pull request #15487 from [BEAM-12812] - Run Github
Actions on GCP workers in the apache-beam-testing project
add 5fa6c3e [BEAM-11097] Add SideInputCache to harness control type
(#15530)
add c901d11 Updated interactive integration test golden screenshots.
add 8fd42bb Merge pull request #15552 from KevinGG/screenshot
add 1386951 Revert PR 15487 (BEAM-12812) (#15554)
add 472be11 [BEAM-12898] Trying out solution suggestion for JENKINS-66189
to solve problem that postBuildScript not running
add 314e260 Merge pull request #15558 from y1chi/beam-12898
add d030576 [BEAM-12898] Use new postbuildscript dsl in Flink load tests
add a84d9cb run postbuild regardless of test result
add e27d8d6 spotless
add b31a7ea Merge pull request #15547 from ibzib/BEAM-12898
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/Flink.groovy | 23 +-
.test-infra/jenkins/Kubernetes.groovy | 25 +-
CHANGES.md | 4 +-
.../dataflow/BatchStatefulParDoOverrides.java | 4 +-
.../dataflow/DataflowPipelineTranslator.java | 3 +-
.../beam/runners/dataflow/DataflowRunner.java | 22 +-
.../beam/runners/dataflow/DataflowRunnerTest.java | 17 +
sdks/go/pkg/beam/core/runtime/harness/harness.go | 10 +
.../java/org/apache/beam/sdk/state/MapState.java | 12 -
.../java/org/apache/beam/sdk/state/SetState.java | 5 +-
.../beam/fn/harness/state/FnApiStateAccessor.java | 239 ++++++++-
.../beam/fn/harness/state/MultimapUserState.java | 292 +++++++++++
.../fn/harness/state/MultimapUserStateTest.java | 557 +++++++++++++++++++++
.../beam/sdk/io/gcp/pubsublite/ReadWriteIT.java | 16 +-
.../Linux/29c9237ddf4f3d5988a503069b4d3c47.png | Bin 65527 -> 65527 bytes
.../Linux/7a35f487b2a5f3a9b9852a8659eeb4bd.png | Bin 728275 -> 728318 bytes
16 files changed, 1188 insertions(+), 41 deletions(-)
create mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/MultimapUserState.java
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/state/MultimapUserStateTest.java
