This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 39ef2d4 Merge pull request #11834: [BEAM-10117] Correct erroneous Job
Failed message
add 5d65ed6 [BEAM-10305] Let StateRequestHandler for user state only use
a single cache token
add bd38c98 Merge pull request #12062: [BEAM-10305] Let
InMemoryBagUserStateFactory only use a single cache token
No new revisions were added by this update.
Summary of changes:
.../functions/FlinkExecutableStageFunction.java | 2 +-
.../streaming/ExecutableStageDoFnOperator.java | 20 +--
.../streaming/ExecutableStageDoFnOperatorTest.java | 123 +++++++++----------
.../state/InMemoryBagUserStateFactory.java | 13 +-
.../fnexecution/state/StateRequestHandlers.java | 37 +++---
.../state/StateRequestHandlersTest.java | 134 +++++++++++++++++++++
.../runners/portability/flink_runner_test.py | 18 +--
.../apache_beam/runners/worker/sdk_worker.py | 6 +-
8 files changed, 219 insertions(+), 134 deletions(-)
