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

HDFS-4400. DFSInputStream#getBlockReader: last retries should ignore the cache. Contributed by Colin Patrick McCabe. 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/HDFS-347@1433144 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Todd Lipcon 2013-01-14 21:34:22 +00:00
parent 12bf674e8e
commit d08b1af26a
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-hdfs-project/hadoop-hdfs/CHANGES.HDFS-347.txt
View File

@ -17,3 +17,5 @@ HDFS-4388. DomainSocket should throw AsynchronousCloseException when appropriate
HDFS-4390. Bypass UNIX domain socket unit tests when they cannot be run. HDFS-4390. Bypass UNIX domain socket unit tests when they cannot be run.
(Colin Patrick McCabe via todd) (Colin Patrick McCabe via todd)
HDFS-4400. DFSInputStream#getBlockReader: last retries should ignore the cache
(Colin Patrick McCabe via todd)

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

@ -941,7 +941,7 @@ public class DFSInputStream extends FSInputStream implements ByteBufferReadable
// equivalent to declaring the DataNode bad. // equivalent to declaring the DataNode bad.
boolean triedNonDomainSocketReader = false; boolean triedNonDomainSocketReader = false;
for (int retries = 0; for (int retries = 0;
retries < nCachedConnRetry && (!triedNonDomainSocketReader); retries < nCachedConnRetry || (!triedNonDomainSocketReader);
++retries) { ++retries) {
Peer peer = null; Peer peer = null;
if (retries < nCachedConnRetry) { if (retries < nCachedConnRetry) {