[
https://issues.apache.org/jira/browse/FLINK-28262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
simenliuxing updated FLINK-28262:
---------------------------------
Attachment: image-2022-06-27-19-06-33-267.png
> The select result does not match the sink table
> -----------------------------------------------
>
> Key: FLINK-28262
> URL: https://issues.apache.org/jira/browse/FLINK-28262
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Planner, Table SQL / Runtime
> Affects Versions: 1.14.0
> Reporter: simenliuxing
> Priority: Major
> Attachments: image-2022-06-27-19-06-33-267.png
>
>
> sql is as follows:
> {code:java}
> CREATE TABLE source
> (
> int_one INT,
> int_two INT
> ) WITH (
> 'connector' = 'datagen'
> ,'rows-per-second' = '1'
> ,'fields.int_one.min' = '1'
> ,'fields.int_one.max' = '1'
> ,'fields.int_two.min' = '2'
> ,'fields.int_two.max' = '2'
> );
> CREATE TABLE sink
> (
> int_one0 INT,
> int_two0 INT
> ) WITH (
> 'connector' = 'print'
> );
> insert into sink
> select
> int_two as int_two0, -- The result I want is to write to the int_two0
> field of the sink table
> int_one as int_one0 -- The result I want is to write to the int_one0
> field of the sink table
> from source;
> {code}
>
> The result is as follows:
> {code:java}
> +I[2, 1]
> +I[2, 1]
> +I[2, 1]{code}
> The problem seems to be here, I want query result and result table to be
> mapped by field name instead of location:
> {code:java}
> select
> int_two as int_two0,
> int_one as int_one0
> from source;{code}
> Will this issue be fixed in a later version?
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
