chunjun
chunjun copied to clipboard
[Bug] [connector jdbc] jdbc toInternal methods should process data by field name rather than index
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
CREATE TABLE tjy_sql1
(
id int,
name string,
face string
) WITH (
'connector' = 'mysql-x',
...
);
CREATE TABLE tjy_sql1_sink
(
name string
) WITH (
'connector' = 'print'
);
insert into tjy_sql1_sink select name from tjy_sql1;
如上flink sql,tjy_sql1_sink获取的字段数据为id所属数据,而不是name所属数据
What you expected to happen
能够安装select选择的字段准确的消费数据
How to reproduce
如上
Anything else
No response
Version
master
Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct