You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sz...@apache.org on 2015/04/30 20:15:01 UTC
hive git commit: HIVE-10384 : RetryingMetaStoreClient does not retry
wrapped TTransportExceptions (Chaoyu Tang via Szehon)
Repository: hive
Updated Branches:
refs/heads/master 9bc1b3bf2 -> b097189f6
HIVE-10384 : RetryingMetaStoreClient does not retry wrapped TTransportExceptions (Chaoyu Tang via Szehon)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b097189f
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b097189f
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b097189f
Branch: refs/heads/master
Commit: b097189f6ed56a173ca49670faa28b0d1d5aa30d
Parents: 9bc1b3b
Author: Szehon Ho <sz...@cloudera.com>
Authored: Thu Apr 30 11:13:52 2015 -0700
Committer: Szehon Ho <sz...@cloudera.com>
Committed: Thu Apr 30 11:14:11 2015 -0700
----------------------------------------------------------------------
.../apache/hadoop/hive/metastore/RetryingMetaStoreClient.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/b097189f/metastore/src/java/org/apache/hadoop/hive/metastore/RetryingMetaStoreClient.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/RetryingMetaStoreClient.java b/metastore/src/java/org/apache/hadoop/hive/metastore/RetryingMetaStoreClient.java
index 5ce58ee..16b4910 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/RetryingMetaStoreClient.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/RetryingMetaStoreClient.java
@@ -115,11 +115,15 @@ public class RetryingMetaStoreClient implements InvocationHandler {
(e.getCause() instanceof TTransportException)) {
caughtException = (TException) e.getCause();
} else if ((e.getCause() instanceof MetaException) &&
- e.getCause().getMessage().matches("(?s).*JDO[a-zA-Z]*Exception.*")) {
+ e.getCause().getMessage().matches
+ ("(?s).*(JDO[a-zA-Z]*|TApplication|TProtocol|TTransport)Exception.*")) {
caughtException = (MetaException) e.getCause();
} else {
throw e.getCause();
}
+ } catch (MetaException e) {
+ if (e.getMessage().matches("(?s).*(IO|TTransport)Exception.*"));
+ caughtException = e;
}
if (retriesMade >= retryLimit) {