storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/2] storm git commit: STORM-933:NullPointerException during KafkaSpout deactivation
Date Sun, 02 Aug 2015 22:59:34 GMT
Repository: storm
Updated Branches:
  refs/heads/0.9.x-branch 67cc2201a -> a58e30cbb


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/d222c312
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d222c312
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d222c312

Branch: refs/heads/0.9.x-branch
Commit: d222c312ad393272fb6a59c3bd56b60536e66fec
Parents: 67cc220
Author: caofangkun <caofangkun@gmail.com>
Authored: Fri Jul 31 10:36:42 2015 +0800
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Mon Aug 3 07:58:38 2015 +0900

----------------------------------------------------------------------
 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/d222c312/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