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

    https://github.com/apache/flink/pull/6035#discussion_r188992099
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
 ---
    @@ -232,8 +239,10 @@ public TaskExecutor(
                        rpcService.getScheduledExecutor(),
                        log);
     
    -           hardwareDescription = HardwareDescription.extractFromSystem(
    +           this.hardwareDescription = 
HardwareDescription.extractFromSystem(
                        
taskExecutorServices.getMemoryManager().getMemorySize());
    +
    +           this.currentRegistrationTimeoutId = null;
    --- End diff --
    
    It's already `null` by default.


---

Reply via email to