You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@drill.apache.org by "Aman Sinha (JIRA)" <ji...@apache.org> on 2014/12/12 23:07:13 UTC

[jira] [Commented] (DRILL-1859) IllegalReferenceCountException in the decoder inside Netty

    [ https://issues.apache.org/jira/browse/DRILL-1859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14244866#comment-14244866 ] 

Aman Sinha commented on DRILL-1859:
-----------------------------------

Explain plan: 
{code}
0: jdbc:drill:zk=local> explain plan for select t2.o_custkey from (select o_orderkey, o_custkey from cp.`tpch/orders.parquet` t1 group by o_orderkey, o_custkey limit 10) t2 order by t2.o_custkey;
+------------+------------+
|    text    |    json    |
+------------+------------+
| 00-00    Screen
00-01      SingleMergeExchange(sort0=[0 ASC])
01-01        SelectionVectorRemover
01-02          Sort(sort0=[$0], dir0=[ASC])
01-03            HashToRandomExchange(dist0=[[$0]])
02-01              Project(o_custkey=[$1])
02-02                SelectionVectorRemover
02-03                  Limit(fetch=[10])
02-04                    UnionExchange
03-01                      HashAgg(group=[{0, 1}])
03-02                        HashToRandomExchange(dist0=[[$0]], dist1=[[$1]])
04-01                          HashAgg(group=[{0, 1}])
04-02                            Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=/tpch/orders.parquet]], selectionRoot=/tpch/orders.parquet, numFiles=1, columns=[`o_orderkey`, `o_custkey`]]])
{code}

> IllegalReferenceCountException in the decoder inside Netty
> ----------------------------------------------------------
>
>                 Key: DRILL-1859
>                 URL: https://issues.apache.org/jira/browse/DRILL-1859
>             Project: Apache Drill
>          Issue Type: Bug
>          Components: Execution - RPC
>    Affects Versions: 0.7.0
>            Reporter: Aman Sinha
>
> The following query does a LIMIT inside a subquery to force a UnionExchange and then does an ORDER-BY outside that will first re-distribute the data before sorting.  It results in a DecoderException in netty.
> {code}
> 0: jdbc:drill:zk=local> alter session set `planner.slice_target` = 10;
> +------------+------------+
> |     ok     |  summary   |
> +------------+------------+
> | true       | planner.slice_target updated. |
> +------------+------------+
> 0: jdbc:drill:zk=local> select t2.o_custkey from (select o_orderkey, o_custkey from cp.`tpch/orders.parquet` t1 group by o_orderkey, o_custkey limit 10) t2 order by t2.o_custkey;
> Query failed: Query failed: Failure while running fragment., refCnt: 0, decrement: 1 
> {code}
> Here's partial output from the logs: (will attach full error log).  
> {code}
> io.netty.handler.codec.DecoderException: io.netty.util.IllegalReferenceCountException: refCnt: 0, decrement: 1
>         io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:99) [netty-codec-4.0.24.Final.jar:4.0.24.Final]
>         io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333) [netty-transport-4.0.24.Final.jar:4.0.24.Final]
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)