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();
}
