chunjun icon indicating copy to clipboard operation
chunjun copied to clipboard

[Bug] [connector jdbc] jdbc toInternal methods should process data by field name rather than index

Open david-gao1 opened this issue 2 years ago • 0 comments

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

david-gao1 avatar Dec 13 '23 03:12 david-gao1