Hi 😀 I've created a custom sink that derived from RichSinkFunction. The Sink function is writing to a local java blocking queue. I run a MiniCluster and test it. I noticed that when the job is completed, the *close*() is called, and than invoke is called afterward few more times with last items. I thought that close should be the last call. any idea why is that?