|
@@ -388,7 +388,6 @@ public class TaskTracker implements MRConstants, TaskUmbilicalProtocol,
|
|
synchronized (rJob) {
|
|
synchronized (rJob) {
|
|
rJob.tasks.add(tip);
|
|
rJob.tasks.add(tip);
|
|
}
|
|
}
|
|
- runningJobs.notify(); //notify the fetcher thread
|
|
|
|
return rJob;
|
|
return rJob;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -964,6 +963,9 @@ public class TaskTracker implements MRConstants, TaskUmbilicalProtocol,
|
|
rjob.localized = true;
|
|
rjob.localized = true;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+ synchronized (runningJobs) {
|
|
|
|
+ runningJobs.notify(); //notify the fetcher thread
|
|
|
|
+ }
|
|
return rjob;
|
|
return rjob;
|
|
}
|
|
}
|
|
|
|
|