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.11 Commit: 84106f48bd084555c495ef7f55e557031c983b65 Parents: 7856a00 Author: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Authored: Fri May 11 18:51:55 2018 +0100 Committer: Pedro Boado <pbo...@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; }
