diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java index b5e4bf086e..ed1c9bc640 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java @@ -8525,7 +8525,7 @@ public NotificationEventResponse getNextNotification(NotificationEventRequest rq } private void lockForUpdate() throws MetaException { - String selectQuery = "select NEXT_EVENT_ID from NOTIFICATION_SEQUENCE"; + String selectQuery = "select \"NEXT_EVENT_ID\" from \"NOTIFICATION_SEQUENCE\""; String selectForUpdateQuery = sqlGenerator.addForUpdateClause(selectQuery); new RetryingExecutor(hiveConf, () -> { Query query = pm.newQuery("javax.jdo.query.SQL", selectForUpdateQuery);