note thread is interrupted on InterruptedException
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d814857a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d814857a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d814857a Branch: refs/heads/gearpump-runner Commit: d814857a6c372ba3f87106d49d3ce1ef7c3c7766 Parents: 85dcfbd Author: manuzhang <owenzhang1...@gmail.com> Authored: Fri Jan 20 13:21:24 2017 +0800 Committer: manuzhang <owenzhang1...@gmail.com> Committed: Fri Jan 20 13:21:24 2017 +0800 ---------------------------------------------------------------------- .../apache/beam/runners/gearpump/GearpumpPipelineResult.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/d814857a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java ---------------------------------------------------------------------- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java index 3dd78de..9e53517 100644 --- a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java +++ b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/GearpumpPipelineResult.java @@ -67,7 +67,13 @@ public class GearpumpPipelineResult implements PipelineResult { do { try { Thread.sleep(defaultWaitInterval.getMillis()); - } catch (InterruptedException e) { + } catch (Exception e) { + if (e instanceof InterruptedException) { + Thread.currentThread().interrupt(); + } + if (e instanceof RuntimeException) { + throw (RuntimeException) e; + } throw new RuntimeException(e); } } while (State.RUNNING == getGearpumpState()
