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:57:33 GMT
Repository: storm
Updated Branches:
  refs/heads/0.10.x-branch 1dd0b52a6 -> f28506686


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

Branch: refs/heads/0.10.x-branch
Commit: 1ab2505e085ed672edb19db3117d9c0f6e6627b7
Parents: 1dd0b52
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:55:55 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/1ab2505e/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