icchux commented on issue #238:
URL:
https://github.com/apache/doris-flink-connector/issues/238#issuecomment-1823754827
get. the reproduction steps follow:
1. mysql create table :
```sql
CREATE TABLE `test1` (
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT
'自增主键',
`state` tinyint(4) DEFAULT NULL COMMENT '状态',
`is_finish` tinyint(4) DEFAULT NULL COMMENT '是否完成',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='测试表';
```
2. use the master branch run main method
org.apache.doris.flink.tools.cdc.CdcTools with parameters :
```java
mysql-sync-database
--database test
--use-new-schema-change
--mysql-conf hostname=***
--mysql-conf port=3306
--mysql-conf username=***
--mysql-conf password=***
--mysql-conf database-name=***
--mysql-conf server-time-zone=UTC
--including-tables "test1"
--sink-conf fenodes=192.168.6.69:8030
--sink-conf username=root
--sink-conf password=***
--sink-conf jdbc-url=jdbc:mysql://192.168.6.69:9030
--sink-conf sink.label-prefix=label
--table-conf replication_num=1
```
3. mysql execute first ddl
```sql
alter table test1
add state_1 tinyint null comment '状态1',
add state_2 tinyint null comment '状态2';
```
the doris won't execute this ddl.
4. mysql execute second ddl
```sql
alter table test1
add state_3 tinyint null comment '状态3',
add state_4 tinyint null comment '状态4';
```
this time doris will sync execute this ddl.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
