[
https://issues.apache.org/jira/browse/DRILL-570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chun Chang updated DRILL-570:
-----------------------------
Attachment: plan3.txt
plan2.txt
plan.txt
plan.txt with all exchange removed. plan2.txt with all exchange kept in the
original plan. plan3.txt with hash exchange but no union exchange.
> with exchange on, group by returns two rows instead of one
> ----------------------------------------------------------
>
> Key: DRILL-570
> URL: https://issues.apache.org/jira/browse/DRILL-570
> Project: Apache Drill
> Issue Type: Bug
> Reporter: Chun Chang
> Attachments: plan.txt, plan2.txt, plan3.txt
>
>
> The following query returned two rows instead of one:
> 0: jdbc:drill:schema=dfs> select cast(customer.country as varchar(20)) as c0
> from customer as customer where UPPER(cast(customer.country as varchar(20)))
> = UPPER('USA') group by cast(customer.country as varchar(20))
> . . . . . . . . . . . . > ;
> +------------+
> | c0 |
> +------------+
> | USA |
> | USA |
> +------------+
> Turn off exchange through physical plan, query return a single row. plan.txt
> with exchange turned off and plan2.txt with exchange turned on.
> [root@qa-node120 bin]# ./submit_plan -f ~/plan.txt -t physical -z
> 10.10.100.120:5181
> 14/04/24 19:27:11 INFO zookeeper.ZooKeeper: Client
> environment:user.dir=/opt/mapr/drill/drill-1.0.0/apache-drill-1.0.0-m2-incubating-SNAPSHOT/bin
> 14/04/24 19:27:11 INFO zookeeper.ZooKeeper: Initiating client connection,
> connectString=10.10.100.120:5181 sessionTimeout=15000
> watcher=com.netflix.curator.ConnectionState@1c688df1
> 14/04/24 19:27:11 INFO zookeeper.ClientCnxn: Opening socket connection to
> server /10.10.100.120:5181
> 14/04/24 19:27:11 INFO zookeeper.ClientCnxn: Socket connection established to
> qa-node120.qa.lab/10.10.100.120:5181, initiating session
> 14/04/24 19:27:11 INFO zookeeper.ClientCnxn: Session establishment complete
> on server qa-node120.qa.lab/10.10.100.120:5181, sessionid = 0x458fdbb7990349,
> negotiated timeout = 15000
> ------------------
> | c0 |
> ------------------
> | USA |
> ------------------
> 1 record selected (0.523000 seconds)
> [root@qa-node120 bin]# ./submit_plan -f ~/plan2.txt -t physical -z
> 10.10.100.120:5181
> 14/04/24 19:28:23 INFO zookeeper.ZooKeeper: Client environment:user.home=/root
> 14/04/24 19:28:23 INFO zookeeper.ZooKeeper: Client
> environment:user.dir=/opt/mapr/drill/drill-1.0.0/apache-drill-1.0.0-m2-incubating-SNAPSHOT/bin
> 14/04/24 19:28:23 INFO zookeeper.ZooKeeper: Initiating client connection,
> connectString=10.10.100.120:5181 sessionTimeout=15000
> watcher=com.netflix.curator.ConnectionState@5b554089
> 14/04/24 19:28:23 INFO zookeeper.ClientCnxn: Opening socket connection to
> server /10.10.100.120:5181
> 14/04/24 19:28:23 INFO zookeeper.ClientCnxn: Socket connection established to
> qa-node120.qa.lab/10.10.100.120:5181, initiating session
> 14/04/24 19:28:23 INFO zookeeper.ClientCnxn: Session establishment complete
> on server qa-node120.qa.lab/10.10.100.120:5181, sessionid = 0x458fdbb799034b,
> negotiated timeout = 15000
> ------------------
> | c0 |
> ------------------
> | USA |
> ------------------
> ------------------
> | c0 |
> ------------------
> | USA |
> ------------------
> 2 records selected (8.166000 seconds)
--
This message was sent by Atlassian JIRA
(v6.2#6252)
