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

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


The following commit(s) were added to refs/heads/release-1.10 by this push:
     new e73494b  [FLINK-14572][test] Print the root cause if job fails in 
BlobsCleanupITCase
e73494b is described below

commit e73494b751be3a1c4c3e53901e42cca8f0741200
Author: Gao Yun <[email protected]>
AuthorDate: Mon Jan 6 14:31:59 2020 +0800

    [FLINK-14572][test] Print the root cause if job fails in BlobsCleanupITCase
---
 .../java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java
index d3b8be7..fdac262 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java
@@ -217,7 +217,10 @@ public class BlobsCleanupITCase extends TestLogger {
                                assertThat(jobResult.getApplicationStatus(), 
is(ApplicationStatus.CANCELED));
                        } else {
                                final JobResult jobResult = resultFuture.get();
-                               assertThat(jobResult.isSuccess(), is(true));
+                               Throwable cause = 
jobResult.getSerializedThrowable()
+                                               .map(throwable -> 
throwable.deserializeError(getClass().getClassLoader()))
+                                               .orElse(null);
+                               
assertThat(ExceptionUtils.stringifyException(cause), jobResult.isSuccess(), 
is(true));
                        }
 
                }

Reply via email to