diff --git a/ql/src/java/org/apache/hadoop/hive/ql/security/authorization/PrivilegeSynchonizer.java b/ql/src/java/org/apache/hadoop/hive/ql/security/authorization/PrivilegeSynchonizer.java index 61e3cec..52909e3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/security/authorization/PrivilegeSynchonizer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/security/authorization/PrivilegeSynchonizer.java @@ -214,12 +214,15 @@ public void run() { LOG.info("Success synchronize privilege " + policyProvider.getClass().getName() + ":" + numDb + " databases, " + numTbl + " tables"); } - // Wait if no exception happens, otherwise, retry immediately - LOG.info("Wait for " + interval + " seconds"); - Thread.sleep(interval * 1000); } catch (Exception e) { LOG.error("Error initializing PrivilegeSynchronizer: " + e.getMessage(), e); } + LOG.info("Wait for " + interval + " seconds"); + try { + Thread.sleep(interval * 1000); + } catch (InterruptedException e) { + // do nothing + } } } }