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