Hi Dawid, Thanks for the update, I also managed to work around it by adding another watermark assignment operator between the join and the window. I’ll have to see if it’s possible to assign watermarks at the source, but even if it is, I worry that the different partitions created by all my keyBy() steps would make it difficult for me to figure out which parts of my pipeline should be idle.
Regards, Alexis.
