You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ai...@apache.org on 2018/06/12 22:32:17 UTC
hive git commit: HIVE-19203: Thread-Safety Issue in HiveMetaStore
(Alice Fan, reviewed by Aihua Xu)
Repository: hive
Updated Branches:
refs/heads/master 230ae3629 -> 6814c8495
HIVE-19203: Thread-Safety Issue in HiveMetaStore (Alice Fan, reviewed by Aihua Xu)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/6814c849
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/6814c849
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/6814c849
Branch: refs/heads/master
Commit: 6814c84951b41486f6c8af07b0a79f8f0938b636
Parents: 230ae36
Author: Aihua Xu <ai...@apache.org>
Authored: Tue Jun 12 15:16:38 2018 -0700
Committer: Aihua Xu <ai...@apache.org>
Committed: Tue Jun 12 15:16:38 2018 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hive/metastore/HiveMetaStore.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/6814c849/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
index 8d7b0c3..7dbdba8 100644
--- a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
+++ b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
@@ -350,11 +350,11 @@ public class HiveMetaStore extends ThriftHiveMetastore {
return null;
}
- private static int nextSerialNum = 0;
+ private static AtomicInteger nextSerialNum = new AtomicInteger();
private static ThreadLocal<Integer> threadLocalId = new ThreadLocal<Integer>() {
@Override
protected Integer initialValue() {
- return nextSerialNum++;
+ return nextSerialNum.getAndIncrement();
}
};