Uploaded image for project: 'Apache Drill'
  1. Apache Drill
  2. DRILL-2050

Accountor closed with outstanding buffer

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: 1.2.0
    • Component/s: Execution - RPC
    • Labels:
      None

      Description

      git.branch=8d1e1affe86a5adca3bc17eeaf7520f0d379a393
      git.commit.time=20.01.2015 @ 23\:02\:03 PST

      The following tpcds-implala-sf1 automation query caused RemoteRpcException. This query works most of the time. But fails on average once in every four or five tries. Test data can be downloaded from

      http://apache-drill.s3.amazonaws.com/files/tpcds-sf1-parquet.tgz

      0: jdbc:drill:schema=dfs.drillTestDir> select
      . . . . . . . . . . . . . . . . . . .>   *
      . . . . . . . . . . . . . . . . . . .> from
      . . . . . . . . . . . . . . . . . . .>   (select
      . . . . . . . . . . . . . . . . . . .>     i.i_manufact_id as imid,
      . . . . . . . . . . . . . . . . . . .>     sum(ss.ss_sales_price) sum_sales
      . . . . . . . . . . . . . . . . . . .>     -- avg(sum(ss.ss_sales_price)) over (partition by i.i_manufact_id) avg_quarterly_sales
      . . . . . . . . . . . . . . . . . . .>   from
      . . . . . . . . . . . . . . . . . . .>     item as i,
      . . . . . . . . . . . . . . . . . . .>     store_sales as ss,
      . . . . . . . . . . . . . . . . . . .>     date_dim as d,
      . . . . . . . . . . . . . . . . . . .>     store as s
      . . . . . . . . . . . . . . . . . . .>   where
      . . . . . . . . . . . . . . . . . . .>     ss.ss_item_sk = i.i_item_sk
      . . . . . . . . . . . . . . . . . . .>     and ss.ss_sold_date_sk = d.d_date_sk
      . . . . . . . . . . . . . . . . . . .>     and ss.ss_store_sk = s.s_store_sk
      . . . . . . . . . . . . . . . . . . .>     and d.d_month_seq in (1212, 1212 + 1, 1212 + 2, 1212 + 3, 1212 + 4, 1212 + 5, 1212 + 6, 1212 + 7, 1212 + 8, 1212 + 9, 1212 + 10, 1212 + 11)
      . . . . . . . . . . . . . . . . . . .>     and ((i.i_category in ('Books', 'Children', 'Electronics')
      . . . . . . . . . . . . . . . . . . .>       and i.i_class in ('personal', 'portable', 'reference', 'self-help')
      . . . . . . . . . . . . . . . . . . .>       and i.i_brand in ('scholaramalgamalg #14', 'scholaramalgamalg #7', 'exportiunivamalg #9', 'scholaramalgamalg #9'))
      . . . . . . . . . . . . . . . . . . .>     or (i.i_category in ('Women', 'Music', 'Men')
      . . . . . . . . . . . . . . . . . . .>       and i.i_class in ('accessories', 'classical', 'fragrances', 'pants')
      . . . . . . . . . . . . . . . . . . .>       and i.i_brand in ('amalgimporto #1', 'edu packscholar #1', 'exportiimporto #1', 'importoamalg #1')))
      . . . . . . . . . . . . . . . . . . .>     and ss.ss_sold_date_sk between 2451911 and 2452275 -- partition key filter
      . . . . . . . . . . . . . . . . . . .>   group by
      . . . . . . . . . . . . . . . . . . .>     i.i_manufact_id,
      . . . . . . . . . . . . . . . . . . .>     d.d_qoy
      . . . . . . . . . . . . . . . . . . .>   ) tmp1
      . . . . . . . . . . . . . . . . . . .> -- where
      . . . . . . . . . . . . . . . . . . .> --   case when avg_quarterly_sales > 0 then abs (sum_sales - avg_quarterly_sales) / avg_quarterly_sales else null end > 0.1
      . . . . . . . . . . . . . . . . . . .> order by
      . . . . . . . . . . . . . . . . . . .>   -- avg_quarterly_sales,
      . . . . . . . . . . . . . . . . . . .>   sum_sales,
      . . . . . . . . . . . . . . . . . . .>   tmp1.imid
      . . . . . . . . . . . . . . . . . . .> limit 100;
      +------------+------------+
      |    imid    | sum_sales  |
      +------------+------------+
      Query failed: RemoteRpcException: Failure while running fragment., Attempted to close accountor with 1 buffer(s) still allocatedfor QueryId: 2b401913-4292-26d4-18b0-f105afe06121, MajorFragmentId: 2, MinorFragmentId: 0.
      
      
      	Total 1 allocation(s) of byte size(s): 771, at stack location:
      		org.apache.drill.exec.memory.TopLevelAllocator$ChildAllocator.takeOwnership(TopLevelAllocator.java:197)
      		org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:119)
      		org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:48)
      		org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:194)
      		org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:173)
      		io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
      		io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
      		io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
      		io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
      		io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
      		io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
      		io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:161)
      		io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
      		io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
      		io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
      		io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
      		io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
      		io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
      		io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130)
      		io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
      		io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
      		io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
      		io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
      		io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
      		java.lang.Thread.run(Thread.java:744)
       [ dcc2416d-625a-4deb-a309-b9caf690d012 on atsqa6c88.qa.lab:31010 ]
      [ dcc2416d-625a-4deb-a309-b9caf690d012 on atsqa6c88.qa.lab:31010 ]
      
      
      java.lang.RuntimeException: java.sql.SQLException: Failure while executing query.
      	at sqlline.SqlLine$IncrementalRows.hasNext(SqlLine.java:2514)
      	at sqlline.SqlLine$TableOutputFormat.print(SqlLine.java:2148)
      	at sqlline.SqlLine.print(SqlLine.java:1809)
      	at sqlline.SqlLine$Commands.execute(SqlLine.java:3766)
      	at sqlline.SqlLine$Commands.sql(SqlLine.java:3663)
      	at sqlline.SqlLine.dispatch(SqlLine.java:889)
      	at sqlline.SqlLine.begin(SqlLine.java:763)
      	at sqlline.SqlLine.start(SqlLine.java:498)
      	at sqlline.SqlLine.main(SqlLine.java:460)
      

      Stack trace in drillbit.log:

      015-01-21 09:50:39,036 [BitServer-2] INFO  o.a.drill.exec.work.foreman.Foreman - State change requested.  RUNNING --> FAILED
      org.apache.drill.exec.rpc.RemoteRpcException: Failure while running fragment., Attempted to close accountor with 1 buffer(s) still allocatedfor QueryId: 2b401913-4292-26d4-18b0-f105afe06121, MajorFragmentId: 2, MinorFragmentId: 0.
      
      
              Total 1 allocation(s) of byte size(s): 771, at stack location:
                      org.apache.drill.exec.memory.TopLevelAllocator$ChildAllocator.takeOwnership(TopLevelAllocator.java:197)
                      org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:119)
                      org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:48)
                      org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:194)
                      org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:173)
                      io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:161)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
                      io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130)
                      io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
                      io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
                      io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
                      io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
                      io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
                      java.lang.Thread.run(Thread.java:744)
       [ dcc2416d-625a-4deb-a309-b9caf690d012 on atsqa6c88.qa.lab:31010 ]
      [ dcc2416d-625a-4deb-a309-b9caf690d012 on atsqa6c88.qa.lab:31010 ]
      
              at org.apache.drill.exec.work.foreman.QueryManager.statusUpdate(QueryManager.java:95) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.control.WorkEventBus.status(WorkEventBus.java:75) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.work.batch.ControlHandlerImpl.handle(ControlHandlerImpl.java:82) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.control.ControlServer.handle(ControlServer.java:60) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.control.ControlServer.handle(ControlServer.java:38) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.RpcBus.handle(RpcBus.java:58) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:194) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:173) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89) [netty-codec-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) [netty-codec-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:161) [netty-codec-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) [netty-common-4.0.24.Final.jar:4.0.24.Final]
              at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51]
      2015-01-21 09:50:39,069 [BitServer-2] ERROR o.a.drill.exec.work.foreman.Foreman - Error 9d88d25a-86d8-41f3-b590-618bac101c1e: RemoteRpcException: Failure while running fragment., Attempted to close accountor with 1 buffer(s) still allocatedfor QueryId: 2b401913-4292-26d4-18b0-f105afe06121, MajorFragmentId: 2, MinorFragmentId: 0.
      
              Total 1 allocation(s) of byte size(s): 771, at stack location:
                      org.apache.drill.exec.memory.TopLevelAllocator$ChildAllocator.takeOwnership(TopLevelAllocator.java:197)
                      org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:119)
                      org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:48)
                      org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:194)
                      org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:173)
                      io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:161)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
                      io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130)
                      io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
                      io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
                      io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
                      io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
                      io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
                      java.lang.Thread.run(Thread.java:744)
       [ dcc2416d-625a-4deb-a309-b9caf690d012 on atsqa6c88.qa.lab:31010 ]
      [ dcc2416d-625a-4deb-a309-b9caf690d012 on atsqa6c88.qa.lab:31010 ]
      
      org.apache.drill.exec.rpc.RemoteRpcException: Failure while running fragment., Attempted to close accountor with 1 buffer(s) still allocatedfor QueryId: 2b401913-4292-26d4-18b0-f105afe06121, MajorFragmentId: 2, MinorFragmentId: 0.
      
      
              Total 1 allocation(s) of byte size(s): 771, at stack location:
                      org.apache.drill.exec.memory.TopLevelAllocator$ChildAllocator.takeOwnership(TopLevelAllocator.java:197)
                      org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:119)
                      org.apache.drill.exec.rpc.data.DataServer.handle(DataServer.java:48)
                      org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:194)
                      org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:173)
                      io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:161)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
                      io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
                      io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
                      io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
                      io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130)
                      io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
                      io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
                      io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
                      io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
                      io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
                      java.lang.Thread.run(Thread.java:744)
       [ dcc2416d-625a-4deb-a309-b9caf690d012 on atsqa6c88.qa.lab:31010 ]
      [ dcc2416d-625a-4deb-a309-b9caf690d012 on atsqa6c88.qa.lab:31010 ]
      
              at org.apache.drill.exec.work.foreman.QueryManager.statusUpdate(QueryManager.java:95) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.control.WorkEventBus.status(WorkEventBus.java:75) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.work.batch.ControlHandlerImpl.handle(ControlHandlerImpl.java:82) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.control.ControlServer.handle(ControlServer.java:60) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.control.ControlServer.handle(ControlServer.java:38) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.RpcBus.handle(RpcBus.java:58) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:194) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:173) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT]
              at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89) [netty-codec-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) [netty-codec-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:161) [netty-codec-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
              at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) [netty-common-4.0.24.Final.jar:4.0.24.Final]
              at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51]
      

        Attachments

          Activity

            People

            • Assignee:
              cchang@maprtech.com Chun Chang
              Reporter:
              cchang@maprtech.com Chun Chang
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: