phoenix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pbo...@apache.org
Subject [4/5] phoenix git commit: PHOENIX-4685 Properly handle connection caching for Phoenix inside RegionServers-addendum(Rajeshbabu)
Date Sun, 13 May 2018 09:49:53 GMT
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 <rajeshbabu@apache.org>
Authored: Fri May 11 18:51:55 2018 +0100
Committer: Pedro Boado <pboado@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;
     }


Mime
View raw message