Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4571#discussion_r136814704
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java
---
@@ -391,5 +391,8 @@ public void run() {
Future<?> cancelFuture = jm.ask(new
JobManagerMessages.CancelJob(jobId), deadline.timeLeft());
Object response = Await.result(cancelFuture,
deadline.timeLeft());
assertTrue("Unexpected response: " + response, response
instanceof JobManagerMessages.CancellationSuccess);
+
+ // make sure, the execution is finished to not influence other
test methods
+ invokeThread.join(deadline.timeLeft().toMillis());
--- End diff --
add `assertFalse(invokeThread.isAlive());` ?
---
