What do the logs of the thrift server say ?? If it does not give any relevant information, I would enable DEBUG level logging on the console.
Also a point to remember is the single-threaded nature of the hive thrift server (atleast upto v0.5) But looking at the logs is what will be the first thing that I would do. The query (map/reduce job) will continue to run even if you shutdown the server since a shutdown does not kill the job submitted to the JobTracker. On Thu, Feb 24, 2011 at 9:36 PM, Ayush Gupta <ay...@glugbot.com> wrote: > Probing this further reveals that the connection is reset by the server in > exactly 10 minutes every time. > > I'm running Hive 0.6. I do not see anything relevant at > http://wiki.apache.org/hadoop/Hive/AdminManual/Configuration but is there > some configuration property which controls this? > > -ayush > > > On Fri, Feb 25, 2011 at 8:23 AM, Ayush Gupta <ay...@glugbot.com> wrote: > >> Hi! I'm having some trouble running queries from a java client against a >> remote Thrift Hive server. Its all setup and quicker queries do run through >> fine. >> >> But queries which run longer than about 10 minutes disconnect the client >> with a "TTransportException: Connection reset" exception.. The query >> continues to run on the Hive server but since the client is disconnected the >> results are "lost". The complete stack trace is below. Does this sound >> familiar to anyone? >> >> org.apache.thrift.transport.TTransportException: java.net.SocketException: >> Connection reset >> at >> org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:127) >> at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) >> at >> org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:314) >> at >> org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:262) >> at >> org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:192) >> at >> org.apache.hadoop.hive.service.ThriftHive$Client.recv_execute(ThriftHive.java:72) >> at >> org.apache.hadoop.hive.service.ThriftHive$Client.execute(ThriftHive.java:57) >> at >> com.wordnik.analytics.data.ReportsRunner$.refreshReport(ReportsRunner.scala:105) >> at >> com.wordnik.analytics.data.ReportsRunner$.refreshDailyReport(ReportsRunner.scala:34) >> at >> com.wordnik.analytics.data.ReportsRunner.refreshDailyReport(ReportsRunner.scala) >> at com.wordnik.analytics.util.Temp.main(Temp.java:11) >> Caused by: java.net.SocketException: Connection reset >> at java.net.SocketInputStream.read(SocketInputStream.java:168) >> at java.io.BufferedInputStream.fill(BufferedInputStream.java:218) >> at java.io.BufferedInputStream.read1(BufferedInputStream.java:258) >> at java.io.BufferedInputStream.read(BufferedInputStream.java:317) >> at >> org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:125) >> ... 10 more >> >> -ayush >> > >
