Rethrow exception so compiler (and others) know about it.
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/39ef1cf9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/39ef1cf9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/39ef1cf9 Branch: refs/heads/master Commit: 39ef1cf94c01605a5cdaac85051b52f74b41184c Parents: d813963 Author: thomas <[email protected]> Authored: Tue Aug 11 10:36:13 2015 -0700 Committer: thomas <[email protected]> Committed: Tue Aug 11 10:36:13 2015 -0700 ---------------------------------------------------------------------- .../main/java/com/datatorrent/stram/StreamingContainerManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/39ef1cf9/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java index 6840288..64850f5 100644 --- a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java +++ b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java @@ -362,7 +362,7 @@ public class StreamingContainerManager implements PlanContext this.containerFile = new FSJsonLineFile(new Path(this.vars.appPath + "/containers"), FsPermission.getDefault()); this.containerFile.append(getAppMasterContainerInfo()); } catch (IOException ex) { - DTThrowable.rethrow(ex); + throw DTThrowable.wrapIfChecked(ex); } }
