This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new cd7b212  [hotfix][coordination] Remove outdated comment
cd7b212 is described below

commit cd7b21235729b5f36190daf14862dbc32c5d1d43
Author: Chesnay Schepler <[email protected]>
AuthorDate: Sat Jun 29 17:07:23 2019 +0200

    [hotfix][coordination] Remove outdated comment
---
 .../src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java      | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java 
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
index f638117..ce949d8 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
@@ -896,7 +896,6 @@ public class JobMaster extends 
FencedRpcEndpoint<JobMasterId> implements JobMast
                validateRunsInMainThread();
 
                if (newJobStatus.isGloballyTerminalState()) {
-                       // other terminal job states are handled by the 
executions
                        runAsync(() -> registeredTaskManagers.keySet()
                                
.forEach(partitionTracker::stopTrackingAndReleasePartitionsFor));
 

Reply via email to