[FLINK-13839] Support to set yarn node label for flink jobmanager and taskmanager container

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Deployment / YARN
• Assignee: Unassigned
• Reporter: Yang Wang
• Created: 23/Aug/19 13:12
• Updated: 28/Oct/19 02:12
• Resolved: 28/Oct/19 02:12

Description

Yarn node label feature is introduced from 2.6. It is a way to group nodes with similar characteristics and applications can specify where to run. In the production or cloud environment, we want to the jobmanager running on some more stable machines. The node label could help us to achieve that.

 

However, the ResourceRequest.setNodeLabelExpression have not been supported in the current hadoop version dependency(2.4.1). So we need to bump the hadoop version to 2.6.5.

Issue Links

• is duplicated by: FLINK-7836 specifying node label for flink job to run on yarn