You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2017/02/24 18:16:13 UTC
[04/11] storm git commit: Fixing minor issue.
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 <kn...@yahoo-inc.com>
Authored: Wed Feb 22 12:26:31 2017 -0600
Committer: Kyle Nusbaum <kn...@yahoo-inc.com>
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);