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

Reply via email to