You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:12:56 UTC
[25/50] incubator-apex-core git commit: Rethrow exception so compiler
(and others) know about it.
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 <th...@datatorrent.com>
Authored: Tue Aug 11 10:36:13 2015 -0700
Committer: thomas <th...@datatorrent.com>
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);
}
}