Uploaded image for project: 'Hive'
  1. Hive
  2. HIVE-7081

HiveServer/HiveServer2 leaks jdbc connections when network interrupt

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 0.12.0, 0.13.0
    • None
    • HiveServer2, JDBC
    • hadoop 1.2.1
      hive 0.12.0 / hive 0.13.0
      linux 2.6.32

    Description

      HiveServer/HiveServer2 leaks jdbc connections when network between client and server is interrupted。
      I test both use DBVisualizer and write JDBC code,when the network between client and hiveserver/hiverserver2 is interrupted,the tcp connection in the server side will be in ESTABLISH state forever util the server is stoped。By Using jstack to print out server's thread, I found thread is doing socketRead0()。

      "pool-1-thread-13" prio=10 tid=0x00007fd00c0c6800 nid=0x5d21 runnable [0x00007fd000180000]
      java.lang.Thread.State: RUNNABLE
      at java.net.SocketInputStream.socketRead0(Native Method)
      at java.net.SocketInputStream.read(SocketInputStream.java:152)
      at java.net.SocketInputStream.read(SocketInputStream.java:122)
      at java.io.BufferedInputStream.fill(BufferedInputStream.java:235)
      at java.io.BufferedInputStream.read1(BufferedInputStream.java:275)
      at java.io.BufferedInputStream.read(BufferedInputStream.java:334)

      • locked <0x00000000ebc24f28> (a java.io.BufferedInputStream)
        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:378)
        at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
        at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
        at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:27)
        at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:206)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at java.lang.Thread.run(Thread.java:745)

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              WangZhiqiang Wang Zhiqiang
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated: