Hi Vipul, Thanks for the information. Yes, I do have checkpointing enabled with 10 millisecs. I think the issue here is that the stream ended before the checkpoint reached. This is a testing code that the DataStream only have 5 events then it ended. Once the stream ended, the checkpoint is not triggered, then the file remains in "pending" state. Anyway we can force a checkpoint trigger? or let the sink know the stream ended? Thanks, Tao
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
