Re-interrupt thread when handling InterruptedException
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8b31c530 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8b31c530 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8b31c530 Branch: refs/heads/master Commit: 8b31c5305b94b643af9c05be998c07f00819017e Parents: 9f8712c Author: Kenneth Knowles <[email protected]> Authored: Thu Mar 31 09:41:51 2016 -0700 Committer: Luke Cwik <[email protected]> Committed: Thu Mar 31 16:22:43 2016 -0700 ---------------------------------------------------------------------- .../test/java/com/google/cloud/dataflow/sdk/util/GcsUtilTest.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8b31c530/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/GcsUtilTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/GcsUtilTest.java b/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/GcsUtilTest.java index 6017969..70fbe1a 100644 --- a/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/GcsUtilTest.java +++ b/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/GcsUtilTest.java @@ -152,6 +152,7 @@ public class GcsUtilTest { countDownLatches[currentLatch - 1].countDown(); } } catch (InterruptedException e) { + Thread.currentThread().interrupt(); throw new RuntimeException(e); } }
