FlinkmiddleWatermarkmechanism useduntiedecidechaossequenceproblem.WatermarkCan it be produced in the following way?
inheritassiknerWithPunctuateca termmarks
Inherit assigner Timestamp WithWatermark
Inherit get Current Watermark
Inherit assignerWithPeriodicWatermarks
Submit