Repository: hadoop Updated Branches: refs/heads/branch-2 3e987446e -> fed2339e2
HADOOP-12901. Add warning log when KMSClientProvider cannot create a connection to the KMS server. (Xiao Chen via wang) (cherry picked from commit 391da36d93358038c50c15d91543f6c765fa0471) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/fed2339e Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/fed2339e Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/fed2339e Branch: refs/heads/branch-2 Commit: fed2339e285e84a40514f877703b2712a2305a6f Parents: 3e98744 Author: Andrew Wang <[email protected]> Authored: Mon Mar 7 14:00:02 2016 -0800 Committer: Andrew Wang <[email protected]> Committed: Mon Mar 7 14:00:08 2016 -0800 ---------------------------------------------------------------------- .../org/apache/hadoop/crypto/key/kms/KMSClientProvider.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/fed2339e/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/KMSClientProvider.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/KMSClientProvider.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/KMSClientProvider.java index a73eda6..1fc9e2b 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/KMSClientProvider.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/KMSClientProvider.java @@ -42,6 +42,8 @@ import org.apache.hadoop.security.token.delegation.web.DelegationTokenAuthentica import org.apache.hadoop.util.HttpExceptionUtils; import org.apache.http.client.utils.URIBuilder; import org.codehaus.jackson.map.ObjectMapper; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import javax.net.ssl.HttpsURLConnection; @@ -85,6 +87,9 @@ import com.google.common.base.Strings; public class KMSClientProvider extends KeyProvider implements CryptoExtension, KeyProviderDelegationTokenExtension.DelegationTokenExtension { + private static final Logger LOG = + LoggerFactory.getLogger(KMSClientProvider.class); + private static final String INVALID_SIGNATURE = "Invalid signature"; private static final String ANONYMOUS_REQUESTS_DISALLOWED = "Anonymous requests are disallowed"; @@ -491,6 +496,9 @@ public class KMSClientProvider extends KeyProvider implements CryptoExtension, } }); } catch (IOException ex) { + if (ex instanceof SocketTimeoutException) { + LOG.warn("Failed to connect to {}:{}", url.getHost(), url.getPort()); + } throw ex; } catch (UndeclaredThrowableException ex) { throw new IOException(ex.getUndeclaredThrowable());
