You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/06/13 13:57:01 UTC
[flink] 01/02: [hotfix][docs] Minor clarification
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
commit dfa0f61d5cecfa8ad91786ecc36cf0209ac25fe1
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Wed Jun 5 14:28:06 2019 +0200
[hotfix][docs] Minor clarification
---
.../main/java/org/apache/flink/runtime/executiongraph/Execution.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
index 48e2f87..5e7677e 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
@@ -801,7 +801,7 @@ public class Execution implements AccessExecution, Archiveable<ArchivedExecution
}
else if (current == FINISHED || current == FAILED) {
- // nothing to do any more. finished failed before it could be cancelled.
+ // nothing to do any more. finished/failed before it could be cancelled.
// in any case, the task is removed from the TaskManager already
sendReleaseIntermediateResultPartitionsRpcCall();