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/11/29 10:38:46 UTC

[beam] branch master updated (13858b4 -> 1f64ba3)

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 13858b4  Merge pull request #10217 from milantracy/beam8406
     add 4575e1c  [BEAM-4776] Add metrics support to Java PortableRunner
     add 1f64ba3  Merge pull request #10105: [BEAM-4776] Add metrics support to Java PortableRunner

No new revisions were added by this update.

Summary of changes:
 .../runners/core/metrics/MetricsPusherTest.java    |  25 ++-
 .../beam/runners/core/metrics/TestMetricsSink.java |  33 ++--
 runners/flink/job-server/flink_job_server.gradle   |   3 -
 .../portability/JobServicePipelineResult.java      |   6 +-
 .../beam/runners/portability/PortableMetrics.java  | 170 +++++++++++++++++++++
 .../portability/testing/TestJobService.java        |  14 +-
 .../runners/portability/PortableRunnerTest.java    | 119 ++++++++++++++-
 .../spark/metrics/SparkMetricsPusherTest.java      |   5 +-
 .../metrics/MetricsPusherTest.java                 |   5 +-
 9 files changed, 354 insertions(+), 26 deletions(-)
 create mode 100644 runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableMetrics.java