[FLINK-9326] TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.5.0
• Fix Version/s: 1.5.1, 1.6.0

Environment

Linux 64bit

Flink branch release-1.5

• Assignee: vinoyang
• Reporter: Samuel Doyle
• Created: 09/May/18 18:40
• Updated: 28/Feb/19 13:21
• Resolved: 29/May/18 11:21

Description

When attempting to set the number of task slots via the api such ash

configuration = new Configuration();
configuration.setInteger(TaskManagerOptions.NUM_TASK_SLOTS, 16);
configuration.setInteger(CoreOptions.DEFAULT_PARALLELISM, 1);

I will always end up with the default slot setting based on the number of cores I have where my standalone instance is running, it doesn't matter what I set the the NUM_TASK_SLOTS to, it has no effect

Issue Links

• links to: GitHub Pull Request #6041