You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nutch.apache.org by mc...@apache.org on 2005/08/02 22:31:38 UTC
svn commit: r227078 -
/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskTracker.java
Author: mc
Date: Tue Aug 2 13:31:37 2005
New Revision: 227078
URL: http://svn.apache.org/viewcvs?rev=227078&view=rev
Log:
Whenever we kill a task for failing to report progress,
log the fact.
Modified:
lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskTracker.java
Modified: lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskTracker.java
URL: http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskTracker.java?rev=227078&r1=227077&r2=227078&view=diff
==============================================================================
--- lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskTracker.java (original)
+++ lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/TaskTracker.java Tue Aug 2 13:31:37 2005
@@ -230,7 +230,7 @@
TaskInProgress tip = (TaskInProgress) it.next();
if ((tip.getRunState() == TaskStatus.RUNNING) &&
(System.currentTimeMillis() - tip.getLastProgressReport() > TASK_MIN_PROGRESS_INTERVAL)) {
-
+ LOG.info("Task " + tip.getTask().getTaskId() + " has not reported progress for a long time. Killing...");
tip.cleanup();
}
}