sentry-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ann...@apache.org
Subject sentry git commit: SENTRY-1155: Add waiting time for getMetastoreClient for avoiding metastore isn't ready (Dapeng Sun, reviewed by Anne Yu).
Date Mon, 04 Apr 2016 23:37:22 GMT
Repository: sentry
Updated Branches:
  refs/heads/master fd047665b -> 812159d96


SENTRY-1155: Add waiting time for getMetastoreClient for avoiding metastore isn't ready (Dapeng
Sun, reviewed by Anne Yu).


Project: http://git-wip-us.apache.org/repos/asf/sentry/repo
Commit: http://git-wip-us.apache.org/repos/asf/sentry/commit/812159d9
Tree: http://git-wip-us.apache.org/repos/asf/sentry/tree/812159d9
Diff: http://git-wip-us.apache.org/repos/asf/sentry/diff/812159d9

Branch: refs/heads/master
Commit: 812159d9608c7ccd5c777a877ea678642a17437b
Parents: fd04766
Author: Anne Yu <anneyu@apache.org>
Authored: Mon Apr 4 17:04:36 2016 -0700
Committer: Anne Yu <anneyu@apache.org>
Committed: Mon Apr 4 17:08:10 2016 -0700

----------------------------------------------------------------------
 .../apache/sentry/tests/e2e/hive/Context.java   | 26 ++++++++++++++------
 1 file changed, 19 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sentry/blob/812159d9/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/Context.java
----------------------------------------------------------------------
diff --git a/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/Context.java
b/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/Context.java
index 2e508d6..a92d8c9 100644
--- a/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/Context.java
+++ b/sentry-tests/sentry-tests-hive/src/test/java/org/apache/sentry/tests/e2e/hive/Context.java
@@ -257,13 +257,25 @@ public class Context {
   // TODO: Handle kerberos login
   public HiveMetaStoreClient getMetaStoreClient(String userName) throws Exception {
     UserGroupInformation clientUgi = UserGroupInformation.createRemoteUser(userName);
-    HiveMetaStoreClient client = (HiveMetaStoreClient) clientUgi.
-        doAs(new PrivilegedExceptionAction<Object> () {
-          @Override
-          public HiveMetaStoreClient run() throws Exception {
-            return new HiveMetaStoreClient(new HiveConf());
-          }
-        });
+    HiveMetaStoreClient client = null;
+    try {
+      client = clientUgi.doAs(new PrivilegedExceptionAction<HiveMetaStoreClient>()
{
+        @Override
+        public HiveMetaStoreClient run() throws Exception {
+          return new HiveMetaStoreClient(new HiveConf());
+        }
+      });
+    } catch (Throwable e) {
+      // The metastore may don't finish the initialization, wait for 10s for the
+      // initialization.
+      Thread.sleep(10 * 1000);
+      client = clientUgi.doAs(new PrivilegedExceptionAction<HiveMetaStoreClient>()
{
+        @Override
+        public HiveMetaStoreClient run() throws Exception {
+          return new HiveMetaStoreClient(new HiveConf());
+        }
+      });
+    }
     return client;
   }
 


Mime
View raw message