Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6041#discussion_r189836110
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java
---
@@ -103,9 +103,16 @@ public JobExecutionResult execute(String jobName)
throws Exception {
configuration.setInteger(RestOptions.PORT, 0);
}
+ int numSlotsPerTaskManager;
+ if (configuration.contains(TaskManagerOptions.NUM_TASK_SLOTS)) {
--- End diff --
this block can be simplified to:
```
numSlotsPerTaskManager =
configuration.getInteger(TaskManagerOptions.NUM_TASK_SLOTS,
jobGraph.getMaximumParallelism());
```
---
