java-不能无一例外地 join到Phoenix?


0

我 join到凤凰城,我面临一个奇怪的问题:在某些机器上我可以成功 join,但我可以得到 join失败。但是当它失败时,它不会抛出任何异常,它被阻塞了,所以我不知道这是怎么回事。我 where可以看到日志?

public class TestPhoenix {

private static String driver = "org.apache.phoenix.jdbc.PhoenixDriver";
private  static  String url = "jdbc:phoenix:192.168.1.91,192.168.1.50,192.168.1.60:2182";

public static void main(String[] args)throws  Exception{

    Class.forName(driver);
    Properties properties = new Properties();

    if (driver.equals("org.apache.phoenix.jdbc.PhoenixDriver")){

        properties.setProperty("phoenix.functions.allowUserDefinedFunctions","true");

    }
    Connection conn = null;
    conn= DriverManager.getConnection(url, properties);

    System.out.println(conn);
}

}

我运行程序时使用:

java -cp phoenix-4.5.1-HBase-1.1.jar:. TestPhoenix

1 答案


0

好的,我发现了问题,我没有在某些机器上配置主机。我将其配置如下:

server.1=data1:2888:3888
server.2=s5:2888:3888
server.3=s6:2888:3888

按如下方式配置hadoop:

<property>
  <name>fs.defaultFS</name>
  <value>hdfs://s5.hadoop.ipin.com:20000</value>
  <description>The name of the default file system.  Either the
  literal string "local" or a host:port for DFS.</description>
</property>

问题是我没有添加数据。hadoop.ipin.com在某些计算机中,我的程序总是试图获取这些主机,因此我将/etc/hosts配置为:

192.168.1.40 s5 s4.hadoop.ipin.com
192.168.1.50 s5 s5.hadoop.ipin.com
192.168.1.60 s6 s6.hadoop.ipin.com
192.168.1.91 data91 data1

这样我就可以成功 join了


我来回答

写文章

提问题

面试题