[hotfix] [tests] Small simplification in 'CheckedThread'.

laubersder · Jan 24, 2018 · 6e894ee · 6e894ee
1 parent 1c9c1e3
commit 6e894ee
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/...t/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/CheckedThread.java b/...t/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/CheckedThread.java
@@ -34,8 +34,6 @@ public abstract class CheckedThread extends Thread {
  /** The error thrown from the main work method. */
  private volatile Throwable error;
 
- private volatile boolean finished = false;
-
  // ------------------------------------------------------------------------
 
  /**
@@ -78,9 +76,6 @@ public final void run() {
  catch (Throwable t) {
  error = t;
  }
- finally {
- finished = true;
- }
  }
 
  /**
@@ -123,7 +118,7 @@ else if (error instanceof Exception) {
  }
 
  private void checkFinished() throws Exception {
- if (!finished) {
+ if (getState() != State.TERMINATED) {
  throw new Exception(String.format(
  "%s[name = %s] has not finished!",
  this.getClass().getSimpleName(),