Matthias Pohl created FLINK-29253: ------------------------------------- Summary: DefaultJobmanagerRunnerRegistry#localCleanupAsync calls close instead of closeAsync Key: FLINK-29253 URL: https://issues.apache.org/jira/browse/FLINK-29253 Project: Flink Issue Type: Bug Components: Runtime / Coordination Affects Versions: 1.15.2, 1.16.0, 1.17.0 Reporter: Matthias Pohl
{{DefaultJobmanagerRunnerRegistry#localCleanupAsync}} is meant to be called from the main thread. The current implementation calls {{close}} on the {{JobManagerRunner}} instead of {{closeAsync}}. This results in a blocking call on the {{Dispatcher}}'s main thread which we want to avoid. -- This message was sent by Atlassian Jira (v8.20.10#820010)