[
https://issues.apache.org/jira/browse/DRILL-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599676#comment-14599676
]
Victoria Markman commented on DRILL-3294:
-----------------------------------------
Verified fixed in 1.1
#Wed Jun 24 04:54:29 EDT 2015
git.commit.id.abbrev=5a34d81
{code}
0: jdbc:drill:schema=dfs> create table wf_t4(a1) as select avg(a1)
over(partition by a1) from t1;
+-----------+----------------------------+
| Fragment | Number of records written |
+-----------+----------------------------+
| 0_0 | 10 |
+-----------+----------------------------+
1 row selected (0.513 seconds)
0: jdbc:drill:schema=dfs> select * from wf_t4;
+-------+
| a1 |
+-------+
| 1.0 |
| 2.0 |
| 3.0 |
| 4.0 |
| 5.0 |
| 6.0 |
| 7.0 |
| 9.0 |
| 10.0 |
| null |
+-------+
10 rows selected (0.17 seconds)
{code}
Automated test will be checked in as part of the ctas suite for window
functions.
> False schema change exception in CTAS with AVG window function
> --------------------------------------------------------------
>
> Key: DRILL-3294
> URL: https://issues.apache.org/jira/browse/DRILL-3294
> Project: Apache Drill
> Issue Type: Bug
> Components: Query Planning & Optimization
> Affects Versions: 1.0.0
> Reporter: Victoria Markman
> Assignee: Jinfeng Ni
> Labels: window_function
> Fix For: 1.1.0
>
> Attachments: t1_parquet
>
>
> This bug could be related to DRILL-3293, but since it's a different function
> and different symptom, I'm filing a new one.
> {code}
> 0: jdbc:drill:schema=dfs> create table wf_t1(a1) as select avg(a1)
> over(partition by a1) from t1;
> Error: SYSTEM ERROR: org.apache.drill.exec.exception.SchemaChangeException:
> Failure while trying to materialize incoming schema. Errors:
>
> Error in expression at index -1. Error: Missing function implementation:
> [castTINYINT(NULL-OPTIONAL)]. Full expression: --UNKNOWN EXPRESSION--..
> Fragment 0:0
> [Error Id: 1ca5af3a-0ea7-4b75-b493-74f6404d4894 on atsqa4-133.qa.lab:31010]
> (state=,code=0)
> {code}
> Query works correctly by itself:
> {code}
> 0: jdbc:drill:schema=dfs> select avg(a1) over(partition by a1) from t1;
> +---------+
> | EXPR$0 |
> +---------+
> | 1 |
> | 2 |
> | 3 |
> | 4 |
> | 5 |
> | 6 |
> | 7 |
> | 9 |
> | 10 |
> | null |
> +---------+
> 10 rows selected (0.181 seconds)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
