[flink] branch release-1.12 updated: fixup! [FLINK-21215][task] Do not overwrite the original CheckpointFailureReason in AsyncCheckpointRunnable

[pn...@apache.org]

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

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


The following commit(s) were added to refs/heads/release-1.12 by this push:
     new 089813be fixup! [FLINK-21215][task] Do not overwrite the original CheckpointFailureReason in AsyncCheckpointRunnable
089813be is described below

commit 089813be22fb610da0616202cbfd169f90a29b4b
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Mon Feb 1 20:18:35 2021 +0100

    fixup! [FLINK-21215][task] Do not overwrite the original CheckpointFailureReason in AsyncCheckpointRunnable
---
 .../flink/streaming/runtime/tasks/AsyncCheckpointRunnableTest.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnableTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnableTest.java
index d6f509b..97c2c7d 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnableTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnableTest.java
@@ -100,7 +100,9 @@ public class AsyncCheckpointRunnableTest {
                 createAsyncRunnable(snapshotsInProgress, environment, true);
         runnable.run();
 
-        Assert.assertSame(((CheckpointException) environment.getCause()).getCheckpointFailureReason(), originalReason);
+        Assert.assertSame(
+                ((CheckpointException) environment.getCause()).getCheckpointFailureReason(),
+                originalReason);
     }
 
     private AsyncCheckpointRunnable createAsyncRunnable(