diff --git standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java index 50e240e..e41c968 100644 --- standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java +++ standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java @@ -10001,10 +10001,13 @@ private void lockNotificationSequenceForUpdate() throws MetaException { new RetryingExecutor(conf, () -> { prepareQuotes(); Query query = pm.newQuery("javax.jdo.query.SQL", lockingQuery); - query.setUnique(true); - // only need to execute it to get db Lock - query.execute(); - query.closeAll(); + try { + query.setUnique(true); + // only need to execute it to get db Lock + query.execute(); + } finally { + query.closeAll(); + } }).run(); } }