big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-7401. Add block info to DFSInputStream' WARN message when it adds node to deadNodes (Contributed by Arshad Mohammad)

Browse Source
This commit is contained in:
Vinayakumar B 2015-05-29 16:36:19 +05:30
parent d725dd8af6
commit b75df697e0
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
View File

@ -819,6 +819,9 @@ Release 2.8.0 - UNRELEASED
HDFS-8407. hdfsListDirectory must set errno to 0 on success (Masatake HDFS-8407. hdfsListDirectory must set errno to 0 on success (Masatake
Iwasaki via Colin P. McCabe) Iwasaki via Colin P. McCabe)
HDFS-7401. Add block info to DFSInputStream' WARN message when it adds
node to deadNodes (Arshad Mohammad via vinayakumarb)
Release 2.7.1 - UNRELEASED Release 2.7.1 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

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

@ -631,8 +631,8 @@ private synchronized DatanodeInfo blockSeekTo(long target) throws IOException {
fetchBlockAt(target); fetchBlockAt(target);
} else { } else {
connectFailedOnce = true; connectFailedOnce = true;
DFSClient.LOG.warn("Failed to connect to " + targetAddr + " for block" DFSClient.LOG.warn("Failed to connect to " + targetAddr + " for block "
+ ", add to deadNodes and continue. " + ex, ex); +targetBlock.getBlock()+ ", add to deadNodes and continue. " + ex, ex);
// Put chosen node into dead list, continue // Put chosen node into dead list, continue
addToDeadNodes(chosenNode); addToDeadNodes(chosenNode);
} }