Tag: phoenix

nodejs通过phoenix和druid连接到hbase

我已经安装了Phoenix-phoenix-4.3.1,并通过sqline成功连接到hbase两台机器都是集群的一部分,另外一台机器不属于集群,也没有hadoop组件。 只是访问zookeeper的sqlline访问是好的,但通过应用程序(npm)通过德鲁伊连接运行到一个错误 我发现npm https://github.com/gaodazhu/phoenix-client 我得到以下 May 22, 2015 2:08:25 AM com.alibaba.druid.pool.DruidDataSource error SEVERE: dataSource init error java.sql.SQLException: org.apache.phoenix.jdbc.PhoenixDriver at com.alibaba.druid.util.JdbcUtils.createDriver(JdbcUtils.java:514) at com.alibaba.druid.pool.DruidDataSource.init(DruidDataSource.java:565) at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:878) at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:874) at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:97) at com.mlsc.DBClient.query(DBClient.java:134) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) Caused by: java.lang.ClassNotFoundException: org.apache.phoenix.jdbc.PhoenixDriver at java.net.URLClassLoader$1.run(URLClassLoader.java:366) at java.net.URLClassLoader$1.run(URLClassLoader.java:355) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:354) at java.lang.ClassLoader.loadClass(ClassLoader.java:425) at […]

node.js和npm jdbc与kerberized apache phoenix的封装问题

我使用nodejs和npm jdbc软件包连接到hortonworks上的Kerberized Apache phoenix,我能够通过nodejs和jdbc软件包连接到非kerberized phoenix,但是面对kerberized phoenix的Kerberos身份validation错误。 如果有人做了类似的事情,请给点方向。 Klist命令: klist -k -t -e /etc/security/keytabs/kafka.headless.keytab Keytab name: FILE:/etc/security/keytabs/kafka.headless.keytab KVNO Timestamp Principal —- —————– ——————————————————– 1 09/30/16 10:10:27 kafka@REALM.LAN (aes256-cts-hmac-sha1-96) 码: var express = require('express'); var app = express(); var server = require('http').Server(app); var https =require('http'); var io = require('socket.io')(server); var kafka = require('kafka-node'); var cassandra = require('cassandra-driver'); […]