Fix TransactionalTopologyBuilder NPE

xumingming · Nathan Marz · commit a5688d0e84a6 · 2012-05-25T11:26:57.000-07:00
diff --git a/src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java b/src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java
@@ -52,7 +52,7 @@ public TransactionalTopologyBuilder(String id, String spoutId, ITransactionalSpo
         _id = id;
         _spoutId = spoutId;
         _spout = spout;
-        _spoutParallelism = spoutParallelism.intValue();
+        _spoutParallelism = (spoutParallelism == null) ? null : spoutParallelism.intValue();
     }
     
     public TransactionalTopologyBuilder(String id, String spoutId, ITransactionalSpout spout) {

Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ public TransactionalTopologyBuilder(String id, String spoutId, ITransactionalSpo`
`52`	`52`	`_id = id;`
`53`	`53`	`_spoutId = spoutId;`
`54`	`54`	`_spout = spout;`
`55`		`- _spoutParallelism = spoutParallelism.intValue();`
	`55`	`+ _spoutParallelism = (spoutParallelism == null) ? null : spoutParallelism.intValue();`
`56`	`56`	`}`
`57`	`57`
`58`	`58`	`public TransactionalTopologyBuilder(String id, String spoutId, ITransactionalSpout spout) {`