Hi Biplop,

If an operator has two inputs, the resulting Watermark is the smallest one
from the two upstreams. More on that you can check here
<https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/event_timestamps_watermarks.html#timestamps-per-kafka-partition>
.

Reply via email to