Author: ddas
Date: Tue Jan 20 23:28:26 2009
New Revision: 736250
URL: http://svn.apache.org/viewvc?rev=736250&view=rev
Log:
Merge -r 728675:728676 from trunk onto 0.18 branch. Fixes HADOOP-4924.
Modified:
hadoop/core/branches/branch-0.18/CHANGES.txt
hadoop/core/branches/branch-0.18/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
Modified: hadoop/core/branches/branch-0.18/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.18/CHANGES.txt?rev=736250&r1=736249&r2=736250&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.18/CHANGES.txt (original)
+++ hadoop/core/branches/branch-0.18/CHANGES.txt Tue Jan 20 23:28:26 2009
@@ -144,6 +144,8 @@
HADOOP-4983. Fixes a problem in updating Counters in the status reporting.
(Amareshwari Sriramadasu via ddas)
+ HADOOP-4924. Fixes a race condition in TaskTracker re-init. (ddas)
+
Release 0.18.2 - 2008-11-03
BUG FIXES
Modified:
hadoop/core/branches/branch-0.18/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
URL:
http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.18/src/mapred/org/apache/hadoop/mapred/TaskTracker.java?rev=736250&r1=736249&r2=736250&view=diff
==============================================================================
---
hadoop/core/branches/branch-0.18/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
(original)
+++
hadoop/core/branches/branch-0.18/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
Tue Jan 20 23:28:26 2009
@@ -769,21 +769,7 @@
for (TaskInProgress tip : tasksToClose.values()) {
tip.jobHasFinished(false);
}
-
- // Shutdown local RPC servers. Do them
- // in parallel, as RPC servers can take a long
- // time to shutdown. (They need to wait a full
- // RPC timeout, which might be 10-30 seconds.)
- new Thread("RPC shutdown") {
- @Override
- public void run() {
- if (taskReportServer != null) {
- taskReportServer.stop();
- taskReportServer = null;
- }
- }
- }.start();
-
+
this.running = false;
// Clear local storage
@@ -794,6 +780,11 @@
// shutdown RPC connections
RPC.stopProxy(jobClient);
+
+ if (taskReportServer != null) {
+ taskReportServer.stop();
+ taskReportServer = null;
+ }
}
/**
