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

YARN-10485. TimelineConnector swallows InterruptedException (#2450). Contributed by Ahmed Hussein

Browse Source
This commit is contained in:
Ahmed Hussein 2020-11-16 14:55:40 -06:00 committed by GitHub
parent dd85a90da6
commit 0b2510ee1f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/pom.xml
View File

@ -45,7 +45,6 @@
<artifactId>hadoop-hdfs-client</artifactId> <artifactId>hadoop-hdfs-client</artifactId>
</dependency> </dependency>
<!-- 'mvn dependency:analyze' fails to detect use of this dependency --> <!-- 'mvn dependency:analyze' fails to detect use of this dependency -->
<dependency> <dependency>
<groupId>org.apache.hadoop</groupId> <groupId>org.apache.hadoop</groupId>

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineConnector.java
View File

@ -19,6 +19,7 @@
package org.apache.hadoop.yarn.client.api.impl; package org.apache.hadoop.yarn.client.api.impl;
import java.io.IOException; import java.io.IOException;
import java.io.InterruptedIOException;
import java.lang.reflect.UndeclaredThrowableException; import java.lang.reflect.UndeclaredThrowableException;
import java.net.ConnectException; import java.net.ConnectException;
import java.net.HttpURLConnection; import java.net.HttpURLConnection;
@ -361,7 +362,8 @@ public Object retryOn(TimelineClientRetryOp op)
// sleep for the given time interval // sleep for the given time interval
Thread.sleep(retryInterval); Thread.sleep(retryInterval);
} catch (InterruptedException ie) { } catch (InterruptedException ie) {
LOG.warn("Client retry sleep interrupted! "); Thread.currentThread().interrupt();
throw new InterruptedIOException("Client retry sleep interrupted!");
} }
} }
throw new RuntimeException("Failed to connect to timeline server. " throw new RuntimeException("Failed to connect to timeline server. "