Re: How to debug window step in flink

2024-04-08 Thread Sachin Mittal
link to know when to emit > a window and therefore you won't see any outgoing events. > > Kind Regards > > Dominik > > > > *From: *Sachin Mittal > *Date: *Monday, 8 April 2024 at 08:17 > *To: *user@flink.apache.org > *Subject: *How to debug window step in flink

Re: How to debug window step in flink

2024-04-07 Thread Dominik.Buenzli
g events. Kind Regards Dominik From: Sachin Mittal Date: Monday, 8 April 2024 at 08:17 To: user@flink.apache.org Subject: How to debug window step in flink Be aware: This is an external email. Hi, I have a following windowing step in my pipeline: inputData .keyBy(new MyKeySelector

How to debug window step in flink

2024-04-07 Thread Sachin Mittal
Hi, I have a following windowing step in my pipeline: inputData .keyBy(new MyKeySelector()) .window( TumblingEventTimeWindows.of(Time.seconds(60))) .reduce(new MyReducer()) .name("MyReducer"); Same step when I see in Flink UI shows as: Window(TumblingEventTimeWindows(60