Fixing minor issue.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6839fec1 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6839fec1 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6839fec1 Branch: refs/heads/master Commit: 6839fec10b94a56f6d9614547f4cabafcd9b355a Parents: a64f135 Author: Kyle Nusbaum <[email protected]> Authored: Wed Feb 22 12:26:31 2017 -0600 Committer: Kyle Nusbaum <[email protected]> Committed: Wed Feb 22 12:26:31 2017 -0600 ---------------------------------------------------------------------- storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/6839fec1/storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java b/storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java index c49e5a0..725f869 100644 --- a/storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java +++ b/storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java @@ -190,8 +190,8 @@ public class Pacemaker implements IServerMessageHandler { private HBMessage deletePath(String path) { String prefix = path.endsWith("/") ? path : (path + "/"); for (String key : heartbeats.keySet()) { - key = key + "/"; - if (key.indexOf(prefix) == 0) + String checkKey = key + "/"; + if (checkKey.indexOf(prefix) == 0) deletePulseId(key); } return new HBMessage(HBServerMessageType.DELETE_PATH_RESPONSE, null);
