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?