when a resource can't be found, log an error and exit rather than throw NPE
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2e44c9e6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2e44c9e6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2e44c9e6 Branch: refs/heads/master Commit: 2e44c9e6a2fb4382950da463fad9f392f8991468 Parents: 11b0151 Author: P. Taylor Goetz <ptgo...@gmail.com> Authored: Thu Apr 2 12:18:12 2015 -0400 Committer: P. Taylor Goetz <ptgo...@gmail.com> Committed: Thu Apr 2 12:18:12 2015 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/storm/flux/parser/FluxParser.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/2e44c9e6/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java ---------------------------------------------------------------------- diff --git a/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java b/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java index 78c52d5..72f8a8e 100644 --- a/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java +++ b/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java @@ -63,6 +63,10 @@ public class FluxParser { String propertiesFile, boolean envSub) throws IOException { Yaml yaml = yaml(); InputStream in = FluxParser.class.getResourceAsStream(resource); + if(in == null){ + LOG.error("Unable to load classpath resource: " + resource); + System.exit(1); + } TopologyDef topology = loadYaml(yaml, in, propertiesFile, envSub); in.close(); if(dumpYaml){