You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by cu...@apache.org on 2006/04/20 20:16:30 UTC
svn commit: r395665 - in /lucene/hadoop/trunk: CHANGES.txt
src/java/org/apache/hadoop/dfs/FSNamesystem.java
Author: cutting
Date: Thu Apr 20 11:16:28 2006
New Revision: 395665
URL: http://svn.apache.org/viewcvs?rev=395665&view=rev
Log:
Fix HADOOP-69. NPE when getting hints for a non-existant file chunk. Contributed by Bryan Pendelton.
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSNamesystem.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewcvs/lucene/hadoop/trunk/CHANGES.txt?rev=395665&r1=395664&r2=395665&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Thu Apr 20 11:16:28 2006
@@ -69,6 +69,9 @@
use. Now a global RPC connection pool is used again, as
originally intended. (cutting)
+20. Fix HADOOP-69. Don't throw a NullPointerException when getting
+ hints for non-existing file split. (Bryan Pendelton via cutting)
+
Release 0.1.1 - 2006-04-08
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSNamesystem.java
URL: http://svn.apache.org/viewcvs/lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSNamesystem.java?rev=395665&r1=395664&r2=395665&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSNamesystem.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/FSNamesystem.java Thu Apr 20 11:16:28 2006
@@ -617,9 +617,11 @@
for (int i = startBlock; i <= endBlock; i++) {
TreeSet containingNodes = (TreeSet) blocksMap.get(blocks[i]);
Vector v = new Vector();
- for (Iterator it = containingNodes.iterator(); it.hasNext(); ) {
+ if (containingNodes != null) {
+ for (Iterator it =containingNodes.iterator(); it.hasNext();) {
DatanodeInfo cur = (DatanodeInfo) it.next();
v.add(cur.getHost());
+ }
}
hosts[i-startBlock] = (UTF8[]) v.toArray(new UTF8[v.size()]);
}