Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5689#discussion_r174140412 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -119,6 +121,11 @@ public void run() { lock.release(); resumingThread.join(); + + Throwable exception = error.get(); + if (exception != null) { + throw new AssertionError(exception); + } --- End diff -- assertNull throws a NPE. This throws the actual exception with stacktrace etc and is the most equivalent to just throwing the exception.
---