Hi team, I'm a newcomer to Flink's window functions, specifically utilizing TumblingProcessingTimeWindows with a configured window duration of 20 minutes. However, I've noticed an anomaly where the window output occurs within 16 to 18 minutes. This has left me uncertain about whether I overlooked a configuration or how to address this issue.
Additionally, my data source is a file continuously read from a directory. I encountered a situation where, upon initiating my Flink job with a file already present in the directory, the window output is generated before the specified window time. I'm seeking guidance on how to resolve this discrepancy. Thanks, Arjun
