I wanted to add that when I used the following the watermark was delayed by
3 hours instead of 2 hours that I would have expected:
AND o.rowtime BETWEEN c.rowtime - INTERVAL '2' hour AND c.rowtime
(time window constraint between o and c: 1st and 3rd table)
Thanks,
Vinod
On Fri, Mar 13, 2020 at
Hi!
We are testing the following 3 way time windowed join to keep the retained
state size small. Using joins for the first time here. It works in unit
tests but we are not able to get expected results in production. We are
still troubleshooting this issue. Can you please help us review this in
cas