Permalink
Browse files

Merge branch 'STORM-2345' of https://github.com/tibkiss/storm into ST…

…ORM-2345-1.0.x-merge
  • Loading branch information...
HeartSaVioR committed Mar 9, 2017
2 parents 748ad66 + d8a0957 commit 87801c3521cf34cbeafb8dbfaaeb0226ff1898c9
Showing with 1 addition and 1 deletion.
  1. +1 −1 storm-core/src/jvm/org/apache/storm/daemon/supervisor/ReadClusterState.java
@@ -155,7 +155,7 @@ public synchronized void run() {
NodeInfo ni = req.get_nodeInfo();
if (host.equals(ni.get_node())) {
Long port = ni.get_port().iterator().next();
Set<TopoProfileAction> actions = filtered.get(port);
Set<TopoProfileAction> actions = filtered.get(port.intValue());
if (actions == null) {
actions = new HashSet<>();
filtered.put(port.intValue(), actions);

0 comments on commit 87801c3

Please sign in to comment.