Re: Negative values using latency marker

2017-11-06 Thread Nico Kruber
nd regards, > Tovi > -Original Message- > From: Nico Kruber [mailto:n...@data-artisans.com] > Sent: יום ו 03 נובמבר 2017 15:22 > To: user@flink.apache.org > Cc: Sofer, Tovi [ICG-IT] <ts72...@imceu.eu.ssmb.com> > Subject: Re: Negative values using latency m

RE: Negative values using latency marker

2017-11-05 Thread Sofer, Tovi
s72...@imceu.eu.ssmb.com> Subject: Re: Negative values using latency marker Hi Tovi, if I see this correctly, the LatencyMarker gets its initial timstamp during creation at the source and the latency is reported as a metric at a sink by comparing the initial timestamp with the current time. If the

Re: Negative values using latency marker

2017-11-03 Thread Nico Kruber
Hi Tovi, if I see this correctly, the LatencyMarker gets its initial timstamp during creation at the source and the latency is reported as a metric at a sink by comparing the initial timestamp with the current time. If the clocks between the two machines involved diverge, e.g. the sinks clock