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..1223452 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/RetryingMetaStoreClient.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/RetryingMetaStoreClient.java @@ -120,6 +120,9 @@ public Object invoke(Object proxy, Method method, Object[] args) throws Throwabl } else { throw e.getCause(); } + } catch (MetaException e) { + if (e.getMessage().matches("(?s).*(IO|TTransport)Exception.*")); + caughtException = e; } if (retriesMade >= retryLimit) {