Repository: phoenix Updated Branches: refs/heads/4.8-HBase-0.98 d80c15587 -> 6dfd56453
PHOENIX-3485 Addendum - Use get() instead of getStrings() for retrieving zkquorum Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/6dfd5645 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6dfd5645 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6dfd5645 Branch: refs/heads/4.8-HBase-0.98 Commit: 6dfd5645377f8818520c33707cc5416380497624 Parents: d80c155 Author: Samarth <[email protected]> Authored: Wed Nov 16 09:38:38 2016 -0800 Committer: Samarth <[email protected]> Committed: Wed Nov 16 09:38:38 2016 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/phoenix/util/QueryUtil.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/6dfd5645/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java b/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java index 2046afb..6a16992 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java @@ -25,7 +25,6 @@ import java.sql.DatabaseMetaData; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; -import java.util.ArrayList; import java.util.List; import java.util.Properties; @@ -37,8 +36,6 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp; -import org.apache.hadoop.hbase.util.Addressing; -import org.apache.hadoop.hbase.zookeeper.ZKConfig; import org.apache.phoenix.hbase.index.util.ImmutableBytesPtr; import org.apache.phoenix.iterate.ResultIterator; import org.apache.phoenix.jdbc.PhoenixConnection; @@ -350,9 +347,8 @@ public final class QueryUtil { // read the hbase properties from the configuration int port = conf.getInt(HConstants.ZOOKEEPER_CLIENT_PORT, HConstants.DEFAULT_ZOOKEPER_CLIENT_PORT); // Build the ZK quorum server string with "server:clientport" list, separated by ',' - final String[] servers = - conf.getStrings(HConstants.ZOOKEEPER_QUORUM, HConstants.LOCALHOST); - String server = Joiner.on(',').join(servers); + final String server = + conf.get(HConstants.ZOOKEEPER_QUORUM, HConstants.LOCALHOST); String znodeParent = conf.get(HConstants.ZOOKEEPER_ZNODE_PARENT, HConstants.DEFAULT_ZOOKEEPER_ZNODE_PARENT); String url = getUrl(server, port, znodeParent, principal);
