Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-15050. Optimize log information when DFSInputStream meet CannotObtainBlockLengthException. Contributed by Xiaoqiao He. 

Signed-off-by: Wei-Chiu Chuang <weichiu@apache.org>
(cherry picked from commit 99af49878cc47f5750b6c0edadc8a4c2fcd7a7c6)
(cherry picked from commit 8ba4e13dcc)
(cherry picked from commit 974706c5fd)
This commit is contained in:
He Xiaoqiao 2019-12-11 16:33:26 -08:00 committed by Wei-Chiu Chuang
parent ba4de45e75
commit b91fda7f1d
2 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/CannotObtainBlockLengthException.java
View File

@ -52,4 +52,16 @@ public class CannotObtainBlockLengthException extends IOException {
super("Cannot obtain block length for " + locatedBlock); super("Cannot obtain block length for " + locatedBlock);
} }
/**
* Constructs an {@code CannotObtainBlockLengthException} with the
* specified LocatedBlock and file that failed to obtain block length.
*
* @param locatedBlock
* The LocatedBlock instance which block length can not be obtained
* @param src The file which include this block
*/
public CannotObtainBlockLengthException(LocatedBlock locatedBlock,
String src) {
super("Cannot obtain block length for " + locatedBlock + " of " + src);
}
} }

2
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java
View File

@ -451,7 +451,7 @@ public class DFSInputStream extends FSInputStream
return 0; return 0;
} }
throw new CannotObtainBlockLengthException(locatedblock); throw new CannotObtainBlockLengthException(locatedblock, src);
} }
public long getFileLength() { public long getFileLength() {