You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by br...@apache.org on 2013/06/27 02:08:47 UTC
git commit: Fixed bad Java comparison (use equals(), not ==).
Updated Branches:
refs/heads/master 60ce48818 -> cf5b42c9a
Fixed bad Java comparison (use equals(), not ==).
Review: https://reviews.apache.org/r/11488
Project: http://git-wip-us.apache.org/repos/asf/incubator-mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-mesos/commit/cf5b42c9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-mesos/tree/cf5b42c9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-mesos/diff/cf5b42c9
Branch: refs/heads/master
Commit: cf5b42c9a9d0758a8c9151efdb14670a0a86af00
Parents: 60ce488
Author: Brenden Matthews <br...@airbnb.com>
Authored: Thu May 23 11:40:20 2013 -0700
Committer: Brenden Matthews <br...@airbnb.com>
Committed: Wed Jun 26 17:08:29 2013 -0700
----------------------------------------------------------------------
hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-mesos/blob/cf5b42c9/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java
----------------------------------------------------------------------
diff --git a/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java b/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java
index c5a63bc..279f84e 100644
--- a/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java
+++ b/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java
@@ -602,7 +602,7 @@ public class MesosScheduler extends TaskScheduler implements Scheduler {
// Remove the task from the map.
for (HttpHost tracker : trackers) {
- if (mesosTrackers.get(tracker).taskId == taskStatus.getTaskId()) {
+ if (mesosTrackers.get(tracker).taskId.equals(taskStatus.getTaskId())) {
LOG.info("Removing terminated TaskTracker: " + tracker);
mesosTrackers.remove(tracker);
}