You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/13 06:28:04 UTC

[jira] [Updated] (FLINK-24306) group by index throw SqlValidatorException

     [ https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Yun Gao updated FLINK-24306:
----------------------------
    Fix Version/s: 1.16.0

> group by index throw SqlValidatorException
> ------------------------------------------
>
>                 Key: FLINK-24306
>                 URL: https://issues.apache.org/jira/browse/FLINK-24306
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / API
>    Affects Versions: 1.12.2, 1.13.1
>            Reporter: zlzhang0122
>            Priority: Major
>             Fix For: 1.15.0, 1.16.0
>
>         Attachments: calcite.png, sql_exception.png
>
>
> We create a table using following DDL:
> {code:java}
> create table if not exists datagen_source ( 
> id int,
> name string,
> sex string,
> age int,
> birthday string,
> proc_time as proctime()
> ) with (
> 'connector' = 'datagen',
> 'rows-per-second' = '10000',
> 'fields.id.kind' = 'random',
> 'fields.id.min' = '1',
> 'fields.id.max' = '2000000');{code}
> When we running 
> {code:java}
> select id, count(*) from datagen_source group by id;{code}
> Everything will be fine.But if we running 
> {code:java}
> select id, count(*) from datagen_source group by 1;{code}
> We will get a SqlValidatorException like this:
>  !sql_exception.png!
> Since MySql\Hive\Spark SQL\etc. all support group by index, I think Flink also should support this syntax too.
>   



--
This message was sent by Atlassian Jira
(v8.20.1#820001)