[flink] branch release-1.6 updated: [FLINK-10946] Silent checkpoint async failures in task executor if job is not runnning

[trohrmann]

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

trohrmann pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.6 by this push:
     new fe967ac  [FLINK-10946] Silent checkpoint async failures in task 
executor if job is not runnning
fe967ac is described below

commit fe967acbba2143d7f9facd2d6ac884649a87782a
Author: Andrey Zagrebin <azagre...@gmail.com>
AuthorDate: Fri Nov 30 14:06:49 2018 +0100

    [FLINK-10946] Silent checkpoint async failures in task executor if job is 
not runnning
---
 .../apache/flink/streaming/api/operators/AbstractStreamOperator.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
index f0ea6d4..6f8918d 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
@@ -415,7 +415,9 @@ public abstract class AbstractStreamOperator<OUT>
                        String snapshotFailMessage = "Could not complete 
snapshot " + checkpointId + " for operator " +
                                getOperatorName() + ".";
 
-                       LOG.info(snapshotFailMessage, snapshotException);
+                       if (!getContainingTask().isCanceled()) {
+                               LOG.info(snapshotFailMessage, 
snapshotException);
+                       }
                        throw new Exception(snapshotFailMessage, 
snapshotException);
                }