svn commit: r585409 - in /lucene/hadoop/trunk: CHANGES.txt src/java/org/apache/hadoop/mapred/JobTracker.java

[dd...@apache.org]

Author: ddas
Date: Wed Oct 17 01:28:45 2007
New Revision: 585409

URL: http://svn.apache.org/viewvc?rev=585409&view=rev
Log:
HADOOP-1973. The FileSystem object would be accessed on the JobTracker through a RPC in the InterTrackerProtocol. The check for the object being null was missing and hence NPE would be thrown sometimes. This issue fixes that problem. Contributed by Amareshwari Sri Ramadesu.

Modified:
    lucene/hadoop/trunk/CHANGES.txt
    lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=585409&r1=585408&r2=585409&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Wed Oct 17 01:28:45 2007
@@ -314,6 +314,11 @@
     than the InterruptedException. This behavior is there for the other long
     running threads in the JobTracker. (Arun C Murthy via ddas)
 
+    HADOOP-1973. The FileSystem object would be accessed on the JobTracker
+    through a RPC in the InterTrackerProtocol. The check for the object being
+    null was missing and hence NPE would be thrown sometimes. This issue fixes
+    that problem.  (Amareshwari Sri Ramadasu via ddas) 
+
   IMPROVEMENTS
 
     HADOOP-1908. Restructure data node code so that block sending and 

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java?rev=585409&r1=585408&r2=585409&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java Wed Oct 17 01:28:45 2007
@@ -1471,6 +1471,9 @@
    * Grab the local fs name
    */
   public synchronized String getFilesystemName() throws IOException {
+    if (fs == null) {
+      throw new IllegalStateException("FileSystem object not available yet");
+    }
     return fs.getName();
   }