You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by "Aman Sinha (JIRA)" <ji...@apache.org> on 2014/04/27 18:26:16 UTC
[jira] [Assigned] (DRILL-220) streaming-aggregate returning an
extra row
[ https://issues.apache.org/jira/browse/DRILL-220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aman Sinha reassigned DRILL-220:
--------------------------------
Assignee: Aman Sinha
> streaming-aggregate returning an extra row
> ------------------------------------------
>
> Key: DRILL-220
> URL: https://issues.apache.org/jira/browse/DRILL-220
> Project: Apache Drill
> Issue Type: Bug
> Affects Versions: 1.0.0-milestone-1
> Reporter: Steven Phillips
> Assignee: Aman Sinha
>
> Here is a physical plan:
> {
> head : {
> type : "APACHE_DRILL_PHYSICAL",
> version : 1,
> generator : {
> type : "optiq",
> info : "na"
> }
> },
> graph : [ {
> pop : "parquet-scan",
> @id : 1,
> entries : [ {
> path : "/tmp/tpc-h/customer"
> } ],
> storageengine : {
> type : "parquet",
> dfsName : "file:///"
> },
> ref : "_MAP",
> fragmentPointer : 0
> }, {
> pop : "project",
> @id : 2,
> exprs : [ {
> ref : "output.NATIONKEY",
> expr : "_MAP.C_NATIONKEY"
> }, {
> ref : "output.CUSTKEY",
> expr : "_MAP.C_CUSTKEY"
> } ],
> child : 1
> }, {
> pop : "sort",
> @id : 3,
> child : 2,
> orderings : [ {
> order : "ASC",
> expr : "NATIONKEY"
> } ],
> reverse : false
> }, {
> pop : "streaming-aggregate",
> @id : 4,
> child : 3,
> keys : [ {
> ref : "NATIONKEY",
> expr : "NATIONKEY"
> } ],
> exprs : [ {
> ref : "CUSTOMERS",
> expr : "count(1) "
> } ]
> }, {
> pop : "screen",
> @id : 5,
> child : 4
> } ]
> }
> It is returning these results:
> -----------------------------------
> | NATIONKEY | CUSTOMERS |
> -----------------------------------
> | 4 | 0 |
> | 0 | 59916 |
> | 1 | 59841 |
> | 2 | 59952 |
> | 3 | 59849 |
> | 4 | 59969 |
> | 5 | 60471 |
> | 6 | 60316 |
> | 7 | 60153 |
> | 8 | 60215 |
> | 9 | 60236 |
> | 10 | 60101 |
> | 11 | 60056 |
> | 12 | 59757 |
> | 13 | 59909 |
> | 14 | 59476 |
> | 15 | 59834 |
> | 16 | 59796 |
> | 17 | 59788 |
> | 18 | 60065 |
> | 19 | 60048 |
> | 20 | 59803 |
> | 21 | 59997 |
> | 22 | 60065 |
> | 23 | 60381 |
> | 24 | 60006 |
> -----------------------------------
--
This message was sent by Atlassian JIRA
(v6.2#6252)