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 ProcessFunction. It makes sense to me that close() might not be callable in that case. But I had parallelism at 24 and I know that other instances of that ProcessFunction were running on machines that were gracefully shutdown yet zero close() functions were invoked. It seems like close() should get called on operators that are shutdown gracefully even in a failure condition. Is that how Flink is supposed to work? Am I missing something?
-- *Gregory Fee* Engineer 425.830.4734 <+14258304734> [image: Lyft] <http://www.lyft.com>
