You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by am...@apache.org on 2015/03/31 07:50:38 UTC
incubator-lens git commit: ELNS-469 : Make threadConnections a
concurrent hashmap (Jaideep Dhok via amareshwari)
Repository: incubator-lens
Updated Branches:
refs/heads/master 72691f12f -> d180c2c4f
ELNS-469 : Make threadConnections a concurrent hashmap (Jaideep Dhok via amareshwari)
Project: http://git-wip-us.apache.org/repos/asf/incubator-lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-lens/commit/d180c2c4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-lens/tree/d180c2c4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-lens/diff/d180c2c4
Branch: refs/heads/master
Commit: d180c2c4f4a2444d5a049075a5630272f5263572
Parents: 72691f1
Author: Jaideep Dhok <jd...@apache.org>
Authored: Tue Mar 31 11:20:30 2015 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
Committed: Tue Mar 31 11:20:30 2015 +0530
----------------------------------------------------------------------
.../src/main/java/org/apache/lens/driver/hive/HiveDriver.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-lens/blob/d180c2c4/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java
----------------------------------------------------------------------
diff --git a/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java b/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java
index 3edce4d..a230515 100644
--- a/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java
+++ b/lens-driver-hive/src/main/java/org/apache/lens/driver/hive/HiveDriver.java
@@ -113,7 +113,7 @@ public class HiveDriver implements LensDriver {
// connections need to be separate for each user and each thread
/** The thread connections. */
private final Map<String, ExpirableConnection> threadConnections =
- new HashMap<String, ExpirableConnection>();
+ new ConcurrentHashMap<String, ExpirableConnection>();
/** The thrift conn expiry queue. */
private final DelayQueue<ExpirableConnection> thriftConnExpiryQueue = new DelayQueue<ExpirableConnection>();