[hotfix] Report failure cause in test

deepfield · Mar 11, 2021 · 282eb17 · 282eb17
1 parent b4c57c0
commit 282eb17
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...s/src/test/java/org/apache/flink/test/checkpointing/utils/SavepointMigrationTestBase.java b/...s/src/test/java/org/apache/flink/test/checkpointing/utils/SavepointMigrationTestBase.java
@@ -205,6 +205,15 @@ protected final void restoreAndExecute(
 
  JobStatus jobStatus = jobStatusFuture.get(5, TimeUnit.SECONDS);
 
+ if (jobStatus == JobStatus.FAILED) {
+ LOG.warn(
+ "Job reached status failed",
+ client.requestJobResult(jobID)
+ .get()
+ .getSerializedThrowable()
+ .get()
+ .deserializeError(ClassLoader.getSystemClassLoader()));
+ }
  assertNotEquals(JobStatus.FAILED, jobStatus);
  } catch (Exception e) {
  fail("Could not connect to job: " + e);