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

HADOOP-17808. ipc.Client to set interrupt flag after catching InterruptedException (#3219)

Browse Source
This commit is contained in:
Viraj Jasani 2021-07-23 10:08:55 +05:30 committed by GitHub
parent 98412ce2e1
commit 3a52bfc5db
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java
View File

@ -1051,7 +1051,10 @@ private synchronized boolean waitForWork() {
if (timeout>0) { if (timeout>0) {
try { try {
wait(timeout); wait(timeout);
} catch (InterruptedException e) {} } catch (InterruptedException e) {
LOG.info("Interrupted while waiting to retrieve RPC response.", e);
Thread.currentThread().interrupt();
}
} }
} }
@ -1383,6 +1386,9 @@ public void stop() {
try { try {
emptyCondition.wait(); emptyCondition.wait();
} catch (InterruptedException e) { } catch (InterruptedException e) {
LOG.info("Interrupted while waiting on all connections to be closed.",
e);
Thread.currentThread().interrupt();
} }
} }
} }