get trigger context from WindowFunction

Hi Flink Community, I have a question about knowing what triggered a window when a window function is executed. We have a case were multiple triggers can fire on a window and it would be helpful to understand which trigger is was once the window function is called. I'm not sure if there's a way

global watermark across multiple kafka consumers

Hi guys, I have a question related to utilizing watermarks with multiple FlinkKakfkaConsumer082 instances. The aim is to have a global watermark across multiple kafka consumers where any message from any kafka partition would update the same watermark. When testing a simple TimeStampExtractor