[ 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)