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

HDFS-10508. DFSInputStream should set thread's interrupt status after catching InterruptException from sleep. Contributed by Jing Zhao.

Browse Source
This commit is contained in:
Masatake Iwasaki 2016-06-09 14:52:29 +09:00
parent 1500a0a300
commit 8ea9bbce26
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -306,6 +306,7 @@ private void waitFor(int waitTime) throws IOException {
try { try {
Thread.sleep(waitTime); Thread.sleep(waitTime);
} catch (InterruptedException e) { } catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new InterruptedIOException( throw new InterruptedIOException(
"Interrupted while getting the last block length."); "Interrupted while getting the last block length.");
} }
@ -417,6 +418,7 @@ private long readBlockLength(LocatedBlock locatedblock) throws IOException {
try { try {
Thread.sleep(500); // delay between retries. Thread.sleep(500); // delay between retries.
} catch (InterruptedException e) { } catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new InterruptedIOException( throw new InterruptedIOException(
"Interrupted while getting the length."); "Interrupted while getting the length.");
} }
@ -1063,6 +1065,7 @@ private DNAddrPair chooseDataNode(LocatedBlock block,
" IOException, will wait for " + waitTime + " msec."); " IOException, will wait for " + waitTime + " msec.");
Thread.sleep((long)waitTime); Thread.sleep((long)waitTime);
} catch (InterruptedException e) { } catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new InterruptedIOException( throw new InterruptedIOException(
"Interrupted while choosing DataNode for read."); "Interrupted while choosing DataNode for read.");
} }