this.executor=rpcService.getExecutor(); | this.executor=java.util.concurrent.Executors.newScheduledThreadPool(Hardware.getNumberCPUCores(),new ExecutorThreadFactory(STR0)); | rpcService.getExecutor() | java.util.concurrent.Executors.newScheduledThreadPool(Hardware.getNumberCPUCores(),new ExecutorThreadFactory(STR0)) | flink | 40dce2909e9a5c3d915bd8c27c3e59bc102e9a15 | org.apache.flink.runtime.taskexecutor.TaskManagerRunner | | | xyz | rpcService.getExecutor() |
---|
| - org.apache.flink.runtime.util.ExecutorThreadFactory
- org.apache.flink.runtime.util.Hardware
| xyz | java.util.concurrent.Executors.newScheduledThreadPool(Hardware.getNumberCPUCores(),new ExecutorThreadFactory(STR0)) |
---|
| AssignedTo | False |