[FLINK-15036] Container startup error will be handled out side of the YarnResourceManager's main thread

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.8.3, 1.9.2, 1.10.0
• Fix Version/s: 1.8.3, 1.9.2, 1.10.0
• Component/s: Deployment / YARN
• Labels: pull-request-available
• Assignee: Yang Wang
• Reporter: Till Rohrmann
• Created: 03/Dec/19 11:02
• Updated: 04/Dec/19 21:17
• Resolved: 04/Dec/19 21:17

Description

With FLINK-13184, we replaced the NMClient with the NMClientAsync. As part of this change, container start up errors are now handled by a callback to NMClientAsync.CallbackHandler. The implementation of NMClientAsync.CallbackHandler#onStartContainerError will be called by the NMClientAsync. Since the implementation does state changing operations, it needs to happen inside of the YarnResourceManager main thread.

Issue Links

• links to: GitHub Pull Request #10407