See the flink watermarking mechanism, feel difficult to understand abstract, not understand why watermark time lost for a few seconds to tell flink to arrive a few seconds later, the triggering time of the event and will not change the system time is the ah, have why to take the biggest timestamp is how this, hope to have a great god in a comprehensible way to introduce

CodePudding user response:

Is translation has a problem, actually should be translated into the water, receiving data is equivalent to float on the surface of the object, the height of the water level will rise will not reduce, whenever a new data came in, will recount the water time, but the results is less than the current water time, does not update the existing water level, when the water reached the triggering time window would trigger a window,
Watermark has a certain significance lies in the disorderly data transmission time fault tolerance rate, if late data in the range of tolerance, may transfer to handle as normal,

CodePudding user response:

1/f, grey reference when ling extremely reply:

is translation has a problem, actually should be translated into the water, receiving data is equivalent to float on the surface of the object, the height of the water level will rise will not reduce, whenever a new data came in, will recount the water time, but the results is less than the current time of the water, will not update the existing water level, when the water reached the triggering time window would trigger a window,
Watermark has a certain significance lies in the disorderly data transmission time fault tolerance rate, if late data in the range of tolerance, may transfer to handle as normal,

is to accept data of time under the water can be normal to accept, the water will not update, over the water, the water will update, is calculated according to the water, is this meaning

CodePudding user response:

Behind is you go in and have a friend also in go, he and you keep a distance, the children only forward not backward, you are likely to retreat, but if you even more slowly than children, is the task you are late for too long, should be ignored,

CodePudding user response:

reference magic_kid_2010 reply: 3/f

is that you walk in, there is a friend also in behind, he and you keep a distance, the children only forward not backward, you are likely to retreat, but if you even more slowly than children, is the task you are late for too long, should be ignored,

should be based on the kid's time is it

CodePudding user response:

I also talk about my understanding of WaterMark - & gt; https://blog.csdn.net/weixin_42261489/article/details/105756384