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.
---
