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