You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/07/17 00:04:05 UTC
[2/3] storm git commit: Update FluxParser.java
Update FluxParser.java
Corrected indentation and redundant close() method.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8ec4c5ba
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8ec4c5ba
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8ec4c5ba
Branch: refs/heads/STORM-942-cherrypick
Commit: 8ec4c5ba0f84736596f46cda2d0da5ddf94eed1a
Parents: 11823a7
Author: Brendan W. Lyon <bl...@datainterfuse.com>
Authored: Thu Jul 16 16:46:05 2015 -0400
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Fri Jul 17 06:57:32 2015 +0900
----------------------------------------------------------------------
.../src/main/java/org/apache/storm/flux/parser/FluxParser.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8ec4c5ba/external/flux/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java
----------------------------------------------------------------------
diff --git a/external/flux/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java b/external/flux/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java
index 27ff677..a15abaa 100644
--- a/external/flux/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java
+++ b/external/flux/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java
@@ -65,7 +65,7 @@ public class FluxParser {
public static TopologyDef parseInputStream(InputStream inputStream, boolean dumpYaml, boolean processIncludes,
String propertiesFile, boolean envSub) throws IOException {
- Yaml yaml = yaml();
+ Yaml yaml = yaml();
if (inputStream == null) {
LOG.error("Unable to load input stream");
@@ -73,7 +73,6 @@ public class FluxParser {
}
TopologyDef topology = loadYaml(yaml, inputStream, propertiesFile, envSub);
- inputStream.close();
if (dumpYaml) {
dumpYaml(topology, yaml);