Hello, I have a question about watermark with idle timeout.
I made an example about it, https://github.com/skonmeme/rare_stream/blob/main/src/main/scala/com/skonuniverse/flink/RareStreamWithIdealTimeout.scala <https://github.com/skonmeme/rare_stream/blob/main/src/main/scala/com/skonuniverse/flink/RareStreamWithIdealTimeout.scala> There is WindowFunction with 5 sec tumbling window and messages are imported per 120 sec. And idle timeout is set by 30 sec. However, when running, first message had been processed after 120 sec, which means next message has been imported. Please, tell me what I misunderstand about idle timeout and how to solve this problem. Thanks, Sung Gon
