Repository: phoenix Updated Branches: refs/heads/4.8-HBase-1.2 d34792f1c -> a0c92f0ce
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/a0c92f0c Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/a0c92f0c Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/a0c92f0c Branch: refs/heads/4.8-HBase-1.2 Commit: a0c92f0ceb85284549b476cd06424f7c01b9440b Parents: d34792f Author: Samarth <[email protected]> Authored: Wed Nov 16 09:42:00 2016 -0800 Committer: Samarth <[email protected]> Committed: Wed Nov 16 09:42:00 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/a0c92f0c/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 dc41352..546c488 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; @@ -349,9 +346,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);
