Hi All,
Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
PhoenixConnection con =
DriverManager.getConnection("jdbc:phoenix:localhost:2181").unwrap(PhoenixConnection.class);
PreparedStatement statement = con.prepareStatement("SELECT *
FROM ORDERS_STAG AS O LEFT JOIN CLIENT AS C ON O.CID=C.CID WHERE C.CID is
null");
rset = statement.executeQuery();
after replaceing phoenix3.1.o Rc2 jars getting exception previouly working
fine...
Exception in thread "main" java.sql.SQLException: Encountered exception in
hash plan [0] execution.
at
org.apache.phoenix.execute.HashJoinPlan.iterator(HashJoinPlan.java:146)
at
org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:211)
at
org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:204)
at
org.apache.phoenix.util.PhoenixContextExecutor.call(PhoenixContextExecutor.java:54)
at
org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:204)
at
org.apache.phoenix.jdbc.PhoenixPreparedStatement.executeQuery(PhoenixPreparedStatement.java:158)
at Client_Data_Load.main(Client_Data_Load.java:61)
Caused by: java.lang.UnsatisfiedLinkError:
org.xerial.snappy.SnappyNative.maxCompressedLength(I)I
at org.xerial.snappy.SnappyNative.maxCompressedLength(Native Method)
at org.xerial.snappy.Snappy.maxCompressedLength(Snappy.java:316)
at
org.apache.phoenix.join.HashCacheClient.serialize(HashCacheClient.java:119)
at
org.apache.phoenix.join.HashCacheClient.addHashCache(HashCacheClient.java:77)
at org.apache.phoenix.execute.HashJoinPlan$1.call(HashJoinPlan.java:119)
at org.apache.phoenix.execute.HashJoinPlan$1.call(HashJoinPlan.java:114)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
