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 862a9c8..50e240e 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 @@ -10069,6 +10069,7 @@ public void addNotificationEvent(NotificationEvent entry) throws MetaException { boolean commited = false; Query query = null; try { + pm.flush(); openTransaction(); lockNotificationSequenceForUpdate(); query = pm.newQuery(MNotificationNextId.class);