|
@@ -424,6 +424,7 @@ public class TaskTracker
|
|
|
"Map-events fetcher for all reduce tasks " + "on " +
|
|
|
taskTrackerName);
|
|
|
mapEventsFetcher.start();
|
|
|
+ this.running = true;
|
|
|
}
|
|
|
|
|
|
public static Class<? extends TaskTrackerInstrumentation> getInstrumentationClass(Configuration conf) {
|
|
@@ -1365,7 +1366,6 @@ public class TaskTracker
|
|
|
public void run() {
|
|
|
try {
|
|
|
startCleanupThreads();
|
|
|
- this.running = true;
|
|
|
boolean denied = false;
|
|
|
while (running && !shuttingDown && !denied) {
|
|
|
boolean staleState = false;
|