set default parallelism of spouts/bolts to 1
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/abf2924e Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/abf2924e Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/abf2924e Branch: refs/heads/master Commit: abf2924e8a89d9b9fc28037a4ce079c607f62939 Parents: 9f5f822 Author: P. Taylor Goetz <[email protected]> Authored: Fri Apr 10 15:47:16 2015 -0400 Committer: P. Taylor Goetz <[email protected]> Committed: Fri Apr 10 15:47:16 2015 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/storm/flux/model/VertexDef.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/abf2924e/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java ---------------------------------------------------------------------- diff --git a/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java b/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java index f8bf607..e71bcc2 100644 --- a/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java +++ b/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java @@ -23,7 +23,8 @@ package org.apache.storm.flux.model; */ public abstract class VertexDef extends BeanDef { - private int parallelism; + // default parallelism to 1 so if it's ommitted, the topology will still function. + private int parallelism = 1; public int getParallelism() { return parallelism;
