在flink sql中如何同步sqlserver的表结构变更 #2519
Unanswered
One-One-Code
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
source sql:
CREATE TABLE oper (
opid STRING,
opcd STRING,
opname STRING,
moditime TIMESTAMP,
PRIMARY KEY (opid) NOT ENFORCED
) WITH (
'connector' = 'sqlserver-cdc',
'hostname' = 'xx',
'port' = '1433',
'username' = 'sa',
'password' = '123456',
'database-name' = 'xx',
'table-name' = 'dbo.xx',
'debezium.include.schema.changes'='true'
);
sink sql:
CREATE TABLE oper_d (
opid STRING,
opcd STRING,
opname STRING,
moditime TIMESTAMP,
PRIMARY KEY (opid) NOT ENFORCED
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://xx:3306/test',
'username' = 'xx',
'password' = 'xx',
'table-name' = 'xx'
);
job: insert into oper_d select * from oper;
按照这种方式数据变更是可以同步的,但是表结构修改无法同步,请问是我配置有问题么?
Beta Was this translation helpful? Give feedback.
All reactions