Hi Gregory,
I tried to reproduce the behaviour you described but in my case (Flink
1.5-SNAPSHOT, using the SocketWindowWordCount adapted to let the first
flatmap be a RichFlatMapFunction with a close() method), the close()
method was actually called on the task manager I did not kill. Since the
Hello! I had a program lose a task manager the other day. The fail over
back to a checkpoint and recovery worked like a charm. However, on one of
my ProcessFunctions I defined a close() method and I noticed that it did
not get called. To be clear, the task manager that failed was running that
