fixed a potential NPE
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3fc80c4b Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3fc80c4b Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3fc80c4b Branch: refs/heads/master Commit: 3fc80c4b0bfc83d2534fab160c72894af044dbc3 Parents: e5564c0 Author: å«ä¹ <[email protected]> Authored: Thu Feb 25 15:25:58 2016 +0800 Committer: å«ä¹ <[email protected]> Committed: Thu Feb 25 15:25:58 2016 +0800 ---------------------------------------------------------------------- storm-core/src/jvm/org/apache/storm/stats/StatsUtil.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/3fc80c4b/storm-core/src/jvm/org/apache/storm/stats/StatsUtil.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/stats/StatsUtil.java b/storm-core/src/jvm/org/apache/storm/stats/StatsUtil.java index c06d7db..75ec292 100644 --- a/storm-core/src/jvm/org/apache/storm/stats/StatsUtil.java +++ b/storm-core/src/jvm/org/apache/storm/stats/StatsUtil.java @@ -1156,6 +1156,9 @@ public class StatsUtil { public static List extractDataFromHb(Map executor2hostPort, Map task2component, Map beats, boolean includeSys, StormTopology topology, String compId) { List ret = new ArrayList(); + if (executor2hostPort == null) { + return ret; + } for (Object o : executor2hostPort.entrySet()) { Map.Entry entry = (Map.Entry) o; List key = (List) entry.getKey();
