Sihua Zhou created FLINK-8816: --------------------------------- Summary: Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Key: FLINK-8816 URL: https://issues.apache.org/jira/browse/FLINK-8816 Project: Flink Issue Type: Bug Components: Distributed Coordination Affects Versions: 1.5.0 Reporter: Sihua Zhou Assignee: Sihua Zhou Fix For: 1.5.0
We should remove the oldWorker only after starting newWorker successfully in {{ResourceManager#registerTaskExecutorInternal}} and javadoc for {{SlotProvider#allocateSlot}} is outdated. -- This message was sent by Atlassian JIRA (v7.6.3#76005)