You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nutch.apache.org by cu...@apache.org on 2005/11/03 22:16:29 UTC
svn commit: r330638 -
/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java
Author: cutting
Date: Thu Nov 3 13:16:28 2005
New Revision: 330638
URL: http://svn.apache.org/viewcvs?rev=330638&view=rev
Log:
Keep trying to restart job tracker.
Modified:
lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java
Modified: lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java
URL: http://svn.apache.org/viewcvs/lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java?rev=330638&r1=330637&r2=330638&view=diff
==============================================================================
--- lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java (original)
+++ lucene/nutch/branches/mapred/src/java/org/apache/nutch/mapred/JobTracker.java Thu Nov 3 13:16:28 2005
@@ -40,10 +40,21 @@
public static void startTracker(NutchConf conf) throws IOException {
if (tracker != null)
throw new IOException("JobTracker already running.");
- tracker = new JobTracker(conf);
+ while (true) {
+ try {
+ tracker = new JobTracker(conf);
+ break;
+ } catch (IOException e) {
+ LOG.log(Level.WARNING, "Starting tracker", e);
+ }
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ }
+ }
tracker.offerService();
-
}
+
public static JobTracker getTracker() {
return tracker;
}