Uploaded image for project: 'Tajo'
  1. Tajo
  2. TAJO-103

netty worker not released after server closed

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 0.2-incubating
    • Fix Version/s: 0.2-incubating
    • Component/s: QueryMaster, RPC
    • Labels:
      None

      Description

      In current implementation shutdown() method in NettyServerBase class doesn't release socket resource.
      After invoke shutdown() method, bellow threads are running.
      NettyServerBase must call factoy's releaseExternalResources() method To release socket resource and worker(netty document http://netty.io/3.5/guide/#start.12).

      "New I/O  worker #16" prio=5 tid=7f944eb0b800 nid=0x11911c000 runnable [11911b000]
         java.lang.Thread.State: RUNNABLE
              at sun.nio.ch.KQueueArrayWrapper.kevent0(Native Method)
              at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:136)
              at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:69)
              at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:69)
              - locked <7f46c5428> (a sun.nio.ch.Util$2)
              - locked <7f46c5440> (a java.util.Collections$UnmodifiableSet)
              - locked <7f4562540> (a sun.nio.ch.KQueueSelectorImpl)
              at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:80)
              at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:64)
              at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:244)
              at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:35)
              at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
              at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
              at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
              at java.lang.Thread.run(Thread.java:680)
      
      "New I/O  worker #15" prio=5 tid=7f944eaf9800 nid=0x119019000 runnable [119018000]
         java.lang.Thread.State: RUNNABLE
              at sun.nio.ch.KQueueArrayWrapper.kevent0(Native Method)
              at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:136)
              at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:69)
              at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:69)
              - locked <7f467c930> (a sun.nio.ch.Util$2)
              - locked <7f467c948> (a java.util.Collections$UnmodifiableSet)
              - locked <7f466ba30> (a sun.nio.ch.KQueueSelectorImpl)
              at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:80)
              at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:64)
              at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:244)
              at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:35)
              at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
              at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
              at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
              at java.lang.Thread.run(Thread.java:680)
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              hjkim Hyoungjun Kim
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: