Siddhesh Kalgaonkar
02/12/2023, 8:50 AMAs a general rule, operators are required to completely process a given watermark before forwarding it downstream. For example, WindowOperator will first evaluate all windows that should be fired, and only after producing all of the output triggered by the watermark will the watermark itself be sent downstream. In other words, all elements produced due to occurrence of a watermark will be emitted before the watermark. Why do we need to send the watermark downstream? Can anyone explain the exact meaning of this paragraph? TIADavid Anderson
02/13/2023, 4:04 PMSiddhesh Kalgaonkar
02/13/2023, 4:24 PMDavid Anderson
02/13/2023, 5:16 PMSiddhesh Kalgaonkar
02/17/2023, 10:54 AM