Repository: hive
Updated Branches:
  refs/heads/master a7c197522 -> 8d9b84294


HIVE-17830: dbnotification fails to work with rdbms other than postgres (Daniel 
Dai, reviewed by Thejas Nair)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/8d9b8429
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/8d9b8429
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/8d9b8429

Branch: refs/heads/master
Commit: 8d9b84294d83c4afff5475523190bca0b0414a73
Parents: a7c1975
Author: Daniel Dai <da...@hortonworks.com>
Authored: Thu Oct 19 10:06:00 2017 -0700
Committer: Daniel Dai <da...@hortonworks.com>
Committed: Thu Oct 19 10:06:00 2017 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/hadoop/hive/metastore/ObjectStore.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/8d9b8429/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
----------------------------------------------------------------------
diff --git 
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
 
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
index af6a570..625830e 100644
--- 
a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
+++ 
b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java
@@ -8575,7 +8575,7 @@ public class ObjectStore implements RawStore, 
Configurable {
   }
 
   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(conf, () -> {
       Query query = pm.newQuery("javax.jdo.query.SQL", selectForUpdateQuery);

Reply via email to