diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/FinalizeOnMasterTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/FinalizeOnMasterTest.java index 5b7e1586ea814..9a2066fdfd0bb 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/FinalizeOnMasterTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/FinalizeOnMasterTest.java @@ -30,6 +30,8 @@ import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.RegisterExtension; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.util.concurrent.ScheduledExecutorService; @@ -45,6 +47,7 @@ * only when the execution graph reaches the successful final state. */ class FinalizeOnMasterTest { + private static final Logger LOG = LoggerFactory.getLogger(FinalizeOnMasterTest.class); @RegisterExtension static final TestExecutorExtension EXECUTOR_RESOURCE = @@ -68,7 +71,11 @@ void testFinalizeIsCalledUponSuccess() throws Exception { scheduler.startScheduling(); final ExecutionGraph eg = scheduler.getExecutionGraph(); - + if (!eg.getState().equals(JobStatus.RUNNING)) { + ErrorInfo ei = eg.getFailureInfo(); + LOG.info("Unexpected state found: Exception as string " + ei.getExceptionAsString()); + LOG.info("Unexpected state found: ErrorInfo as string " + ei); + } assertThat(eg.getState()).isEqualTo(JobStatus.RUNNING); ExecutionGraphTestUtils.switchAllVerticesToRunning(eg);