您的位置: 首页  >  技术问答  >  Apache Phoenix JDBC连接动物园管理员错误

Apache Phoenix JDBC连接动物园管理员错误

分类: 技术问答 • 2022-08-23 22:56:06
问题描述：

我已将Phoenix安装在具有3个动物园管理员节点的5节点Cloudera群集上。Apache Phoenix JDBC连接动物园管理员错误

我想从下面的JDBC程序运行一个基本的SQL命令，但我得到zookeeper错误。有人可以提供意见吗？

import java.sql.*; 

public class PhoenixJDBC { 

public static void main(String args[]) { 

try { 
    //Register JDBC Driver 
    Class.forName("org.apache.phoenix.jdbc.PhoenixDriver").newInstance(); 

    Connection conn = DriverManager.getConnection("jdbc:phoenix:54.152.31.122","",""); 

    //Create a Statement class to execute the SQL statement 
    Statement stmt = conn.createStatement(); 

    //Execute the SQL statement and get the results in a Resultset 
    ResultSet rs = stmt.executeQuery("select * from US_POPULATION"); 

    // Iterate through the ResultSet, displaying two values 
    // for each row using the getString method 

    while (rs.next()) 
     System.out.println("Name= " + rs.getString("host")); 
} 
catch (SQLException e) { 
    e.printStackTrace(); 
} 
catch (Exception e) { 
    e.printStackTrace(); 
} 
} 
}

例外：

org.apache.phoenix.exception.PhoenixIOException: org.apache.hadoop.hbase.MasterNotRunningException: Can't get connection to ZooKeeper: KeeperErrorCode = ConnectionLoss for /hbase 
    at org.apache.phoenix.util.ServerUtil.parseServerException(ServerUtil.java:108) 
    at org.apache.phoenix.query.ConnectionQueryServicesImpl.ensureTableCreated(ConnectionQueryServicesImpl.java:832) 
    at org.apache.phoenix.query.ConnectionQueryServicesImpl.createTable(ConnectionQueryServicesImpl.java:1126) 
    at org.apache.phoenix.query.DelegateConnectionQueryServices.createTable(DelegateConnectionQueryServices.java:110) 
    at org.apache.phoenix.schema.MetaDataClient.createTableInternal(MetaDataClient.java:1590) 
    at org.apache.phoenix.schema.MetaDataClient.createTable(MetaDataClient.java:568) 
    at org.apache.phoenix.compile.CreateTableCompiler$2.execute(CreateTableCompiler.java:175) 
    at org.apache.phoenix.jdbc.PhoenixStatement$2.call(PhoenixStatement.java:271) 
    at org.apache.phoenix.jdbc.PhoenixStatement$2.call(PhoenixStatement.java:263) 
    at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53) 
    at org.apache.phoenix.jdbc.PhoenixStatement.executeMutation(PhoenixStatement.java:261) 
    at org.apache.phoenix.jdbc.PhoenixStatement.executeUpdate(PhoenixStatement.java:1043) 
    at org.apache.phoenix.query.ConnectionQueryServicesImpl$9.call(ConnectionQueryServicesImpl.java:1551) 
    at org.apache.phoenix.query.ConnectionQueryServicesImpl$9.call(ConnectionQueryServicesImpl.java:1520) 
    at org.apache.phoenix.util.PhoenixContextExecutor.call(PhoenixContextExecutor.java:77) 
    at org.apache.phoenix.query.ConnectionQueryServicesImpl.init(ConnectionQueryServicesImpl.java:1520) 
    at org.apache.phoenix.jdbc.PhoenixDriver.getConnectionQueryServices(PhoenixDriver.java:162) 
    at org.apache.phoenix.jdbc.PhoenixEmbeddedDriver.connect(PhoenixEmbeddedDriver.java:126) 
    at org.apache.phoenix.jdbc.PhoenixDriver.connect(PhoenixDriver.java:133) 
    at java.sql.DriverManager.getConnection(Unknown Source) 
    at java.sql.DriverManager.getConnection(Unknown Source) 
    at mysqljbdctest.PhoenixJDBC.main(PhoenixJDBC.java:15) 
Caused by: org.apache.hadoop.hbase.MasterNotRunningException: org.apache.hadoop.hbase.MasterNotRunningException: Can't get connection to ZooKeeper: KeeperErrorCode = ConnectionLoss for /hbase 
    at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation$StubMaker.makeStub(HConnectionManager.java:1651) 
    at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation$MasterServiceStubMaker.makeStub(HConnectionManager.java:1677) 
    at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.getKeepAliveMasterService(HConnectionManager.java:1884) 
    at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.getHTableDescriptor(HConnectionManager.java:2671) 
    at org.apache.hadoop.hbase.client.HBaseAdmin.getTableDescriptor(HBaseAdmin.java:397) 
    at org.apache.hadoop.hbase.client.HBaseAdmin.getTableDescriptor(HBaseAdmin.java:402) 
    at org.apache.phoenix.query.ConnectionQueryServicesImpl.ensureTableCreated(ConnectionQueryServicesImpl.java:764) 
    ... 20 more

答

从它看起来像HMASTER可能已关闭的堆栈跟踪。

此外，你有没有尝试在你的网址输入完整的动物园管理员法定人数？事情是这样的：

jdbc:phoenix:54.152.31.122,54.152.31.123,54.152.31.124

我对亚马逊的一个问题（是在您的集群？），其中内部和外部的IP地址都感到困惑和动物园管理员无法连接到HBase的正确。我通过在集群中指向内部IP地址的机器上的/ etc/hosts中创建别名，然后在本地桌面上使用相同的别名（但指向外部IP）来解决此问题（不是最具扩展性的解决方案，但它起作用！然后，改变我的群集设置，以便在别处使用别名而不是IP地址。快速测试这是否是您的问题 - 构建您的应用程序，将其复制到群集中的一台服务器上，然后查看它是否可以正常运行。

希望有帮助！

答

/hbase是Zookeeper中的默认目录。您必须在hbase-site.xml中检查hbase在Zookeeper中保存的路径 - 可能是/ hbase-unsecure。

让我们尝试

jdbc:phoenix:zk-host:port:path_on_zookeeper

相关推荐