Hi all, I have below queries in flink. Could anyone help me to understand?
Query: 1 Is watermark maintained globally at the operator level? 2 When we have a keyByOperator with parallelism >1, is there a single watermark maintained across all the parallel subtasks or for each of the parallel subtasks 3. Assuming I have a keybyoperator with parallelism > 1, is it possible to feed data to this operator from only one stream from the previous parameter (say map (1) always goes to window (1) Regards, Gnana
