storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/3] storm git commit: STORM-933:NullPointerException during KafkaSpout deactivation
Date Sun, 02 Aug 2015 22:54:42 GMT
Repository: storm
Updated Branches:
  refs/heads/master 6de597a6d -> aae4ba63e


STORM-933:NullPointerException during KafkaSpout deactivation


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2a1a417f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2a1a417f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2a1a417f

Branch: refs/heads/master
Commit: 2a1a417f922cbce6239b5c85eb75363b92b9a2d0
Parents: 14fdab8
Author: caofangkun <caofangkun@gmail.com>
Authored: Fri Jul 31 10:36:42 2015 +0800
Committer: caofangkun <caofangkun@gmail.com>
Committed: Fri Jul 31 10:36:42 2015 +0800

----------------------------------------------------------------------
 external/storm-kafka/src/jvm/storm/kafka/ZkCoordinator.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/2a1a417f/external/storm-kafka/src/jvm/storm/kafka/ZkCoordinator.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/ZkCoordinator.java b/external/storm-kafka/src/jvm/storm/kafka/ZkCoordinator.java
index 0a8fe36..3af648c 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/ZkCoordinator.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/ZkCoordinator.java
@@ -33,7 +33,7 @@ public class ZkCoordinator implements PartitionCoordinator {
     int _totalTasks;
     String _topologyInstanceId;
     Map<Partition, PartitionManager> _managers = new HashMap();
-    List<PartitionManager> _cachedList;
+    List<PartitionManager> _cachedList = new ArrayList<PartitionManager>();
     Long _lastRefreshTime = null;
     int _refreshFreqMs;
     DynamicPartitionConnections _connections;


Mime
View raw message