fix typo

Nathan Marz · Nathan Marz · commit 20a29802b056 · 2012-01-25T22:38:24.000-08:00
diff --git a/src/jvm/backtype/storm/transactional/TransactionalSpoutCoordinator.java b/src/jvm/backtype/storm/transactional/TransactionalSpoutCoordinator.java
@@ -57,7 +57,7 @@ public void open(Map conf, TopologyContext context, SpoutOutputCollector collect
         _coordinator = _spout.getCoordinator(conf, context);
         _currTransaction = getStoredCurrTransaction(_state);
         if(!conf.containsKey(Config.TOPOLOGY_MAX_SPOUT_PENDING)) {
-            _maxTransactionActive = 0;
+            _maxTransactionActive = 1;
         } else {
             _maxTransactionActive = Utils.getInt(conf.get(Config.TOPOLOGY_MAX_SPOUT_PENDING));
         }

Original file line number	Diff line number	Diff line change
`@@ -57,7 +57,7 @@ public void open(Map conf, TopologyContext context, SpoutOutputCollector collect`
`57`	`57`	`_coordinator = _spout.getCoordinator(conf, context);`
`58`	`58`	`_currTransaction = getStoredCurrTransaction(_state);`
`59`	`59`	`if(!conf.containsKey(Config.TOPOLOGY_MAX_SPOUT_PENDING)) {`
`60`		`- _maxTransactionActive = 0;`
	`60`	`+ _maxTransactionActive = 1;`
`61`	`61`	`} else {`
`62`	`62`	`_maxTransactionActive = Utils.getInt(conf.get(Config.TOPOLOGY_MAX_SPOUT_PENDING));`
`63`	`63`	`}`