We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
CREATE TABLE tjy_sql1 ( id int, name string, face string ) WITH ( 'connector' = 'mysql-x', ... );
id
name
face
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所属数据
能够安装select选择的字段准确的消费数据
如上
No response
master
The text was updated successfully, but these errors were encountered:
[hotfix-DTStack#1853] [connector jdbc] jdbc toInternal methods should…
5fdb962
… process data by field name rather than index DTStack#1853
d788087
[hotfix-#1853] [connector jdbc] jdbc toInternal methods should proces…
9bbdb45
…s data by field name rather than index #1853
No branches or pull requests
Search before asking
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?
Code of Conduct
The text was updated successfully, but these errors were encountered: