You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/08/03 00:57:33 UTC
[1/2] storm git commit: STORM-933:NullPointerException during
KafkaSpout deactivation
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 <ca...@gmail.com>
Authored: Fri Jul 31 10:36:42 2015 +0800
Committer: Jungtaek Lim <ka...@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;
[2/2] storm git commit: add STORM-933 to CHANGELOG.md
Posted by ka...@apache.org.
add STORM-933 to CHANGELOG.md
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f2850668
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f2850668
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f2850668
Branch: refs/heads/0.10.x-branch
Commit: f2850668618b2160bc614112bf478aeaff54a9d6
Parents: 1ab2505
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Mon Aug 3 07:57:16 2015 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Mon Aug 3 07:57:16 2015 +0900
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/f2850668/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index ee80a39..f239f39 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -175,6 +175,7 @@
* STORM-503: Short disruptor queue wait time leads to high CPU usage when idle
* STORM-728: Put emitted and transferred stats under correct columns
* STORM-643: KafkaUtils repeatedly fetches messages whose offset is out of range
+ * STORM-933: NullPointerException during KafkaSpout deactivation
## 0.9.5
* STORM-790: Log "task is null" instead of let worker died when task is null in transfer-fn