You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mx...@apache.org on 2019/10/29 09:45:37 UTC

[beam] branch master updated (cdfedf0 -> 7811838)

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(-)