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));