You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by om...@apache.org on 2011/03/04 05:46:34 UTC
svn commit: r1077706 -
/hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
Author: omalley
Date: Fri Mar 4 04:46:34 2011
New Revision: 1077706
URL: http://svn.apache.org/viewvc?rev=1077706&view=rev
Log:
commit 18f236422b03dbfa1bc75aac3413833de8e693ba
Author: Chris Douglas <cd...@apache.org>
Date: Sun Sep 19 17:00:06 2010 -0700
Avoid JobLocalizer hang on RPC init by not acquiring lock on localizing job in MapEventsFetcherThread
Modified:
hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
Modified: hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/TaskTracker.java?rev=1077706&r1=1077705&r2=1077706&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/TaskTracker.java (original)
+++ hadoop/common/branches/branch-0.20-security-patches/src/mapred/org/apache/hadoop/mapred/TaskTracker.java Fri Mar 4 04:46:34 2011
@@ -380,7 +380,6 @@ public class TaskTracker implements MRCo
RunningJob rJob = null;
if (!runningJobs.containsKey(jobId)) {
rJob = new RunningJob(jobId);
- rJob.localized = false;
rJob.tasks = new HashSet<TaskInProgress>();
runningJobs.put(jobId, rJob);
} else {
@@ -768,6 +767,9 @@ public class TaskTracker implements MRCo
List <FetchStatus> fList = new ArrayList<FetchStatus>();
for (Map.Entry <JobID, RunningJob> item : runningJobs.entrySet()) {
RunningJob rjob = item.getValue();
+ if (!rjob.localized) {
+ continue;
+ }
JobID jobId = item.getKey();
FetchStatus f;
synchronized (rjob) {
@@ -3157,7 +3159,7 @@ public class TaskTracker implements MRCo
private Path localizedJobConf;
// keep this for later use
volatile Set<TaskInProgress> tasks;
- boolean localized;
+ volatile boolean localized;
boolean keepJobFiles;
UserGroupInformation ugi;
FetchStatus f;