phoenix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajeshb...@apache.org
Subject phoenix git commit: PHOENIX-4685 Properly handle connection caching for Phoenix inside RegionServers-addendum(Rajeshbabu)
Date Fri, 11 May 2018 17:51:13 GMT
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.3 72fa8749e -> 39b92bf9e


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/4.x-HBase-1.3
Commit: 39b92bf9e8d9cae46b1fa230d91ac04a8e49e629
Parents: 72fa874
Author: Rajeshbabu Chintaguntla <rajeshbabu@apache.org>
Authored: Fri May 11 23:20:52 2018 +0530
Committer: Rajeshbabu Chintaguntla <rajeshbabu@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;
     }


Mime
View raw message