Hi there, While still struggling with events and watermarks out of order after sorting with a buffer process function (compare [1]) I tired to solve the issue by assigning a new watermark after the mentioned sorting function.
The Flink docs [2] are not very certain about the impact of assigning additional watermarks downstream: "If the original stream had timestamps and/or watermarks already, the timestamp assigner overwrites them.” Does it overwrite the watermark from the point in the stream where its assigned or entirely also upstream? Thanks in advance Peter [1] https://lists.apache.org/thread/wwvpg2qk5v3lb5pxhn4hhkt0xkygg9f3 [2] https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/datastream/event-time/generating_watermarks/#using-watermark-strategies
