OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
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))flink40dce2909e9a5c3d915bd8c27c3e59bc102e9a15org.apache.flink.runtime.taskexecutor.TaskManagerRunner
_166
_288
_1executor
_2executor
xyzrpcService.getExecutor()
  • org.apache.flink.runtime.util.ExecutorThreadFactory
  • org.apache.flink.runtime.util.Hardware
xyzjava.util.concurrent.Executors.newScheduledThreadPool(Hardware.getNumberCPUCores(),new ExecutorThreadFactory(STR0))
AssignedToFalse