Hi,
I am attempting to create a JDBC Client to HiveServer2.
I have set the following property to support concurrency
<property>
<name>hive.support.concurrency</name>
<description>Enable Hive's Table Lock Manager Service</description>
<value>true</value>
</property>
The JDBC client spawns multiple threads using a executor service and each
thread tries to get a connection to the hiveserver2.
After each thread gets a connection to the hiveserver2, I am attempting to
execute queries independently on each of the thread.
However I am not able to execute the queries on the threads. Any
help/pointers would be appreciated.
Here are the error messages that I see.
org.apache.thrift.transport.
TTransportException: SASL authentication not complete
at
org.apache.thrift.transport.TSaslTransport.write(TSaslTransport.java:444)
at
org.apache.thrift.transport.TSaslClientTransport.write(TSaslClientTransport.java:37)
at
org.apache.thrift.protocol.TBinaryProtocol.writeI32(TBinaryProtocol.java:163)
at
org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin(TBinaryProtocol.java:91)
at org.apache.thrift.TServiceClient.sendBase(TServiceClient.java:62)
at
org.apache.hive.service.cli.thrift.TCLIService$Client.send_FetchResults(TCLIService.java:483)
at
org.apache.hive.service.cli.thrift.TCLIService$Client.FetchResults(TCLIService.java:475)
at
org.apache.hive.jdbc.HiveQueryResultSet.next(HiveQueryResultSet.java:225)
at moz.jdbc.ParExec$MultiHiveConnections.call(ParExec.java:46)
at moz.jdbc.ParExec$MultiHiveConnections.call(ParExec.java:1)
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)
Exception in thread "main" java.util.concurrent.ExecutionException:
java.sql.SQLException: Error retrieving next row
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
at java.util.concurrent.FutureTask.get(FutureTask.java:83)
at moz.jdbc.ParExec.main(ParExec.java:108)
Caused by: java.sql.SQLException: Error retrieving next row
at
org.apache.hive.jdbc.HiveQueryResultSet.next(HiveQueryResultSet.java:247)
at moz.jdbc.ParExec$MultiHiveConnections.call(ParExec.java:46)
at moz.jdbc.ParExec$MultiHiveConnections.call(ParExec.java:1)
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)
--
_________________________________________________________
Regards,
Varun
