flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sofer, Tovi " <tovi.so...@citi.com>
Subject Negative values using latency marker
Date Thu, 02 Nov 2017 16:58:51 GMT
Hi group,

Can someone maybe elaborate how can latency gauge shown by latency marker be negative?

2017-11-02 18:54:56,842 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.Sink: FinalSink.0.latency:
{LatencySourceDescriptor{vertexID=1, subtaskIndex=0}={p99=-5.0, p50=-5.0, min=-5.0, max=-5.0,
p95=-5.0, mean=-5.0}, LatencySourceDescriptor{vertexID=1, subtaskIndex=1}={p99=-5.0, p50=-5.0,
min=-5.0, max=-5.0, p95=-5.0, mean=-5.0}, LatencySourceDescriptor{vertexID=1, subtaskIndex=2}={p99=-6.0,
p50=-6.0, min=-6.0, max=-6.0, p95=-6.0, mean=-6.0}, LatencySourceDescriptor{vertexID=1, subtaskIndex=3}={p99=-6.0,
p50=-6.0, min=-6.0, max=-6.0, p95=-6.0, mean=-6.0}}
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.AverageE2ELatencyChecker.0.60SecWarmUpRecordsCounter:
2858446
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.Source: fixTopicConsumerSource.3.numRecordsOut:
1954784
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.AverageE2ELatencyChecker.0.ActualRecordsCounter:
4962675
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.AverageE2ELatencyChecker.0.AverageLatencyMs:
0.0753785
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.AverageE2ELatencyChecker.0.HighLatencyMsgPercentage:
0.5918576
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.Source: fixTopicConsumerSource.0.numRecordsOutPerSecond:
12943.116666666667
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.AverageE2ELatencyChecker.0.numRecordsInPerSecond:
51751.4
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.Source: fixTopicConsumerSource.3.numRecordsOutPerSecond:
12935.05
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.Source: fixTopicConsumerSource.2.numRecordsOutPerSecond:
12946.916666666666
2017-11-02 18:54:56,843 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.Source: fixTopicConsumerSource.1.numRecordsOutPerSecond:
12926.316666666668
2017-11-02 18:54:56,844 INFO  com.citi.artemis.flink.reporters.ArtemisReporter - [Flink-MetricRegistry-1]
127.0.0.1.taskmanager.f40ca57104c8642218e5b8979a380ee4.Flink Streaming Job.AverageE2ELatencyChecker.0.LatencyHistogram:
count:10000 min:24753 max:19199891 mean:77637.6484 stddev:341333.9414842662 p50:40752.0 p75:49809.0
p95:190480.95 p98:539110.8199999994 p99:749224.8899999995 p999:3817927.9259998496

Regards,
Tovi


Mime
View raw message