Re: Negative values using latency marker

2017-11-06 Thread Nico Kruber
> > Thanks and 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] > Subject: Re: Negative values using latency marker > > Hi To

RE: Negative values using latency marker

2017-11-05 Thread Sofer, Tovi
: 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 clocks between the two machines

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 fa