You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/06/03 19:35:37 UTC
[23/50] [abbrv] storm git commit: set default parallelism of
spouts/bolts to 1
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 <pt...@gmail.com>
Authored: Fri Apr 10 15:47:16 2015 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
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;