[beam] branch master updated (7f04e5f -> 5345005)

[lc...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 7f04e5f  Merge pull request #10694: [BEAM-9132] Fix shutdown issues with the environment
     add 203ca10  Only cache first page of paginated state.
     add 05d8830  Perform bundle-level caching if no cache token is given.
     add a4929a9  [BEAM-8298] Support side input cache tokens.
     add f776da4  fix continuation token iter
     add 8e30655  lint for side input tokens
     add cd58afe  Fix state cache test.
     add dacdb88  TODO about two-level caching.
     add 3cf8305  CachingStateHandler unit test.
     add 2a869c2  test lint
     add 9c99c88  Fix extending non-list.
     add 3b4b1cb  Fix flink counters test.
     add 5345005  [BEAM-8298] Implement side input caching.

No new revisions were added by this update.

Summary of changes:
 .../runners/portability/flink_runner_test.py       |  37 ++++---
 .../apache_beam/runners/worker/sdk_worker.py       | 117 ++++++++++++++++-----
 .../apache_beam/runners/worker/sdk_worker_test.py  | 113 ++++++++++++++++++++
 .../apache_beam/runners/worker/statecache.py       |  38 +++----
 .../apache_beam/runners/worker/statecache_test.py  |  47 +++------
 5 files changed, 257 insertions(+), 95 deletions(-)