You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ar...@apache.org on 2018/10/16 16:26:12 UTC

[beam] branch master updated (e6d7dfe -> 1d36dff)

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

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


    from e6d7dfe  Merge pull request #6705: Inform contributors to tag PRs with R: @reviewer
     add 0abb8bf  [BEAM-4553] Implement graphite sink for MetricsPusher
     add 5505196  [BEAM-3310] Extract CustomQueryResults to be used in all metrics sinks tests.
     add 416b946  [BEAM-3310] Introduce NetworkMockServer to be used for all metrics sinks tests
     add 8de693e  [BEAM-4553] Test Graphite metrics sink
     add 9a3bc3c  [BEAM-3310] improve http sink test
     add ed19748  [BEAM-4553] support runners that do not support committed metrics
     add bd3b353  [BEAM-4553] Refactor MetricsGraphiteSink for code deduplication.
     add d5b32d4  [BEAM-3310] Replace Thread.sleep with a CountDownLatch in all metrics sinks tests to avoid flakiness of the tests.
     new 1d36dff  Merge pull request #6569: [BEAM-4553] Implement graphite sink for MetricsPusher and refactor MetricsHttpSink test

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../extensions/metrics/MetricsGraphiteSink.java    | 328 +++++++++++++++++++++
 .../extensions/metrics/MetricsHttpSink.java        |   4 +-
 .../metrics/CustomMetricQueryResults.java          | 140 +++++++++
 .../metrics/MetricsGraphiteSinkTest.java           | 112 +++++++
 .../extensions/metrics/MetricsHttpSinkTest.java    | 210 +++++--------
 .../extensions/metrics/NetworkMockServer.java      | 112 +++++++
 .../apache/beam/sdk/options/PipelineOptions.java   |  11 +
 7 files changed, 782 insertions(+), 135 deletions(-)
 create mode 100644 runners/extensions-java/metrics/src/main/java/org/apache/beam/runners/extensions/metrics/MetricsGraphiteSink.java
 create mode 100644 runners/extensions-java/metrics/src/test/java/org/apache/beam/runners/extensions/metrics/CustomMetricQueryResults.java
 create mode 100644 runners/extensions-java/metrics/src/test/java/org/apache/beam/runners/extensions/metrics/MetricsGraphiteSinkTest.java
 create mode 100644 runners/extensions-java/metrics/src/test/java/org/apache/beam/runners/extensions/metrics/NetworkMockServer.java


[beam] 01/01: Merge pull request #6569: [BEAM-4553] Implement graphite sink for MetricsPusher and refactor MetricsHttpSink test

Posted by ar...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit 1d36dff31cdbeefa456824cf68148c705160d19f
Merge: e6d7dfe d5b32d4
Author: Alexey Romanenko <33...@users.noreply.github.com>
AuthorDate: Tue Oct 16 18:26:06 2018 +0200

    Merge pull request #6569: [BEAM-4553] Implement graphite sink for MetricsPusher and refactor MetricsHttpSink test

 .../extensions/metrics/MetricsGraphiteSink.java    | 328 +++++++++++++++++++++
 .../extensions/metrics/MetricsHttpSink.java        |   4 +-
 .../metrics/CustomMetricQueryResults.java          | 140 +++++++++
 .../metrics/MetricsGraphiteSinkTest.java           | 112 +++++++
 .../extensions/metrics/MetricsHttpSinkTest.java    | 210 +++++--------
 .../extensions/metrics/NetworkMockServer.java      | 112 +++++++
 .../apache/beam/sdk/options/PipelineOptions.java   |  11 +
 7 files changed, 782 insertions(+), 135 deletions(-)