You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by pb...@apache.org on 2018/05/13 09:49:53 UTC
[4/5] 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/84106f48
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/84106f48
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/84106f48
Branch: refs/heads/4.x-cdh5.12
Commit: 84106f48bd084555c495ef7f55e557031c983b65
Parents: 7856a00
Author: Rajeshbabu Chintaguntla <ra...@apache.org>
Authored: Fri May 11 18:51:55 2018 +0100
Committer: Pedro Boado <pb...@apache.org>
Committed: Sun May 13 10:46:05 2018 +0100
----------------------------------------------------------------------
.../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/84106f48/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;
}