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

    https://github.com/apache/flink/pull/6132#discussion_r198491333
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java
 ---
    @@ -278,4 +279,13 @@ void heartbeatFromTaskManager(
         * not available (yet).
         */
        CompletableFuture<OperatorBackPressureStatsResponse> 
requestOperatorBackPressureStats(JobVertexID jobVertexId);
    +
    +   /**
    +    * Notifies that the task manager has terminated.
    +    *
    +    * @param resourceID identifying the task manager
    +    * @param allocationIDs held by this job that belong to the task manager
    +    * @param cause of the task manager termination
    +    */
    +   void taskManagerTerminated(ResourceID resourceID, Set<AllocationID> 
allocationIDs, Exception cause);
    --- End diff --
    
    methods should usually be a verb. What about `notifyTaskManagerTermination`?


---

Reply via email to