This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch release-1.5
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 60bab12 [FLINK-10316] [kinesis] bug was preventing
FlinkKinesisProducer to connect to Kinesalite
new c864736 [hotfix][tests] Extend MockEnvironmentBuilder to support
TaskManagerRuntimeInfo
new 0ff9dec [FLINK-10242][tests] Split StreamSourceOperatorTest
new 2a1abd4 [FLINK-10242][metrics] Make latency interval configurable
new a5ee4ba [FLINK-10243][metrics] Make latency metrics granularity
configurable
The 4 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:
docs/_includes/generated/metric_configuration.html | 10 +
docs/monitoring/metrics.md | 8 +-
.../apache/flink/api/common/ExecutionConfig.java | 19 +-
.../apache/flink/configuration/MetricOptions.java | 15 ++
.../operators/testutils/MockEnvironment.java | 9 +-
.../testutils/MockEnvironmentBuilder.java | 11 +-
.../api/operators/AbstractStreamOperator.java | 27 ++-
.../streaming/api/operators/StreamSource.java | 13 +-
.../apache/flink/streaming/util/LatencyStats.java | 74 +++++-
.../StreamSourceOperatorLatencyMetricsTest.java | 253 +++++++++++++++++++++
...ava => StreamSourceOperatorWatermarksTest.java} | 99 +-------
.../flink/streaming/util/LatencyStatsTest.java | 217 ++++++++++++++++++
12 files changed, 643 insertions(+), 112 deletions(-)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/StreamSourceOperatorLatencyMetricsTest.java
rename
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/{StreamSourceOperatorTest.java
=> StreamSourceOperatorWatermarksTest.java} (75%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/LatencyStatsTest.java
