Skip to content

Conversation

@oatiz
Copy link
Contributor

@oatiz oatiz commented Aug 29, 2025

related: #360

@caiq1nyu
Copy link
Collaborator

caiq1nyu commented Sep 3, 2025

LGTM,we will review it as soon as possible

@caiq1nyu
Copy link
Collaborator

caiq1nyu commented Sep 4, 2025

能否提供一下用于复现这个case的来源库的建表语句,以及MySQL版本。关联issue里缺少一些结论细节

@oatiz
Copy link
Contributor Author

oatiz commented Sep 5, 2025

能否提供一下用于复现这个case的来源库的建表语句,以及MySQL版本。关联issue里缺少一些结论细节

MySQL:

docker run --name mysql-5.7 -e MYSQL_ROOT_PASSWORD=123456 -p 33061:3306 -d mysql:5.7.44

sql

create database ape_dts_src;
create database ape_dts_dst;

use ape_dts_src;

CREATE TABLE `current_timestamp_case` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `key` varchar(255) NOT NULL,
  `value` varchar(5000) NOT NULL,
  `is_deleted` tinyint(4) DEFAULT NULL,
  `created_at` datetime DEFAULT CURRENT_TIMESTAMP,
  `last_updated_at` datetime(6) DEFAULT CURRENT_TIMESTAMP(6) ON UPDATE CURRENT_TIMESTAMP(6),
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

ape-dts

[extractor]
extract_type=struct
db_type=mysql
url=mysql://root:123456@127.0.0.1:33061?ssl-mode=disabled

[sinker]
sink_type=struct
db_type=mysql
url=mysql://root:123456@127.0.0.1:33061?ssl-mode=disabled

[filter]
do_dbs=ape_dts_src

[router]
db_map=ape_dts_src:ape_dts_dst

[parallelizer]
parallel_type=serial

[pipeline]
buffer_size=100
checkpoint_interval_secs=1

@caiq1nyu caiq1nyu merged commit edc1af8 into apecloud:main Sep 15, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants