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 cdfedf0 Merge pull request #9842: [BEAM-8442] Remove duplicate code
for bundle register in Python SDK harness
add 70caac8 [BEAM-8383] Fix gauge metrics in Python SDK and Flink runner
add 175a2bc [BEAM-8383] Add metrics for the Python state cache
add 7811838 Merge pull request #9769: [BEAM-8383] Add metrics for the
Python state cache
No new revisions were added by this update.
Summary of changes:
.../beam/runners/core/metrics/GaugeData.java | 3 +-
.../runners/core/metrics/MetricsContainerImpl.java | 13 ++-
.../flink/metrics/FlinkMetricContainer.java | 12 +-
.../flink/metrics/FlinkMetricContainerTest.java | 4 +-
.../python/apache_beam/metrics/monitoring_infos.py | 19 ++++
.../runners/portability/flink_runner_test.py | 101 +++++++++++++----
.../runners/portability/fn_api_runner.py | 6 +-
.../apache_beam/runners/worker/bundle_processor.py | 14 ++-
.../apache_beam/runners/worker/sdk_worker.py | 20 +++-
.../apache_beam/runners/worker/statecache.py | 119 +++++++++++++++++++-
.../apache_beam/runners/worker/statecache_test.py | 123 ++++++++++++++++-----
11 files changed, 357 insertions(+), 77 deletions(-)
