Hi, everyone. I have a checkpoint issue with windo...
# troubleshooting
l
Hi, everyone. I have a checkpoint issue with window. I have a Flink job that consumes Kafka topic data, then use a TumblingProcessingTimeWindows with 10 minutes size and the checkpoint(aligned) interval is 4 minutes. When some data is in the window but window is not triggered, meanwhile a checkpoint is triggered and succeed. Before window is triggered, an OOM is occurred in TM, after TM restarted, all data in window is missing(checkpoint succeed, so the offset is push forward). I think this is because checkpoint barriers just ignore the window and flow forward, so data in window is missing, right?