[GitHub] flink pull request #6041: [FLINK-9326] TaskManagerOptions.NUM_TASK_SLOTS doe...

[yanghua]

Github user yanghua commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6041#discussion_r190187802
  
    --- 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 --
    
    cc @zentol


---