You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ja...@apache.org on 2018/05/22 20:39:55 UTC
[12/22] phoenix git commit: PHOENIX-4685 Properly handle connection
caching for Phoenix inside RegionServers-addendum(Rajeshbabu)
PHOENIX-4685 Properly handle connection caching for Phoenix inside RegionServers-addendum(Rajeshbabu)
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/39b92bf9
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/39b92bf9
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/39b92bf9
Branch: refs/heads/omid2
Commit: 39b92bf9e8d9cae46b1fa230d91ac04a8e49e629
Parents: 72fa874
Author: Rajeshbabu Chintaguntla <ra...@apache.org>
Authored: Fri May 11 23:20:52 2018 +0530
Committer: Rajeshbabu Chintaguntla <ra...@apache.org>
Committed: Fri May 11 23:20:52 2018 +0530
----------------------------------------------------------------------
.../src/main/java/org/apache/phoenix/util/ServerUtil.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/39b92bf9/phoenix-core/src/main/java/org/apache/phoenix/util/ServerUtil.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/util/ServerUtil.java b/phoenix-core/src/main/java/org/apache/phoenix/util/ServerUtil.java
index 9190373..891839a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/ServerUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/ServerUtil.java
@@ -346,8 +346,8 @@ public class ServerUtil {
ClusterConnection connection = null;
if((connection = connections.get(connectionType)) == null) {
synchronized (CoprocessorHConnectionTableFactory.class) {
- if(connections.get(connectionType) == null) {
- connection = new CoprocessorHConnection(conf, server);
+ if((connection = connections.get(connectionType)) == null) {
+ connection = new CoprocessorHConnection(getTypeSpecificConfiguration(connectionType, conf), server);
connections.put(connectionType, connection);
return connection;
}
@@ -405,7 +405,7 @@ public class ServerUtil {
}
public static Configuration getIndexWriterConfigurationWithCustomThreads(Configuration conf) {
- Configuration clonedConfig = PropertiesUtil.cloneConfig(conf);
+ Configuration clonedConfig = getIndexWriterConnection(conf);
setHTableThreads(clonedConfig);
return clonedConfig;
}