Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.2 141686ab5 -> 64b77450a
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/64b77450 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/64b77450 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/64b77450 Branch: refs/heads/4.x-HBase-1.2 Commit: 64b77450a8ca45686f7e7d0abf14231dccda2d32 Parents: 141686a Author: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Authored: Fri May 11 23:21:55 2018 +0530 Committer: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Committed: Fri May 11 23:21:55 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/64b77450/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; }
