[beam] branch master updated: [BEAM-5386] Move assertion out of finally block to not swallow original exception

[thw]

This is an automated email from the ASF dual-hosted git repository.

thw pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 926361b  [BEAM-5386] Move assertion out of finally block to not 
swallow original exception
926361b is described below

commit 926361bcb54129a71c7f5abf5817148f8a7d4d41
Author: Thomas Weise <t...@apache.org>
AuthorDate: Sun Dec 30 13:23:33 2018 -0800

    [BEAM-5386] Move assertion out of finally block to not swallow original 
exception
---
 .../translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java
 
b/runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java
index dc93f8f..9edde35 100644
--- 
a/runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java
+++ 
b/runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java
@@ -678,8 +678,8 @@ public class UnboundedSourceWrapperTest {
         thread.interrupt();
         // try to join but also don't mask exceptions with test timeout
         thread.join(1000);
-        assertThat(thread.isAlive(), is(false));
       }
+      assertThat(thread.isAlive(), is(false));
     }
   }