fixed typo in PartitionManager
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/77b17110 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/77b17110 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/77b17110 Branch: refs/heads/master Commit: 77b171107ba52daac34ebf3d8c59d7643ecb6408 Parents: 8c0dcb1 Author: Pete Prokopowicz <pprokopow...@groupon.com> Authored: Thu Oct 1 16:48:14 2015 -0500 Committer: Pete Prokopowicz <pprokopow...@groupon.com> Committed: Thu Oct 1 16:48:14 2015 -0500 ---------------------------------------------------------------------- external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/77b17110/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java index afff87c..10405fa 100644 --- a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java +++ b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java @@ -136,7 +136,7 @@ public class PartitionManager { return EmitState.NO_EMITTED; } Iterable<List<Object>> tups = KafkaUtils.generateTuples(_spoutConfig, toEmit.msg); - if ((tups != null) && tups.iterator.hasNext()) { + if ((tups != null) && tups.iterator().hasNext()) { if(_spoutConfig.topicAsStreamId) { for (List<Object> tup : tups) { collector.emit(_spoutConfig.topic, tup, new KafkaMessageId(_partition, toEmit.offset));
