Shammon created FLINK-25085: ------------------------------- Summary: Add a scheduled thread pool in JM and close it when job terminates Key: FLINK-25085 URL: https://issues.apache.org/jira/browse/FLINK-25085 Project: Flink Issue Type: Sub-task Components: Runtime / Coordination Affects Versions: 1.13.3, 1.12.5, 1.14.0 Reporter: Shammon
Add a dedicated thread pool in JM to schedule tasks that have a long delay such as PhysicalSlotRequestBulkCheckerImpl, heatbeat checker and some other timeout checker. Job should shut down the thread pool and all the pending tasks will be removed when it terminates. -- This message was sent by Atlassian Jira (v8.20.1#820001)