SET execution.result-mode=tableau;
SET execution.checkpointing.interval=10sec;
SET enable_insert_strict = true;
DROP TABLE IF EXISTS person;
CREATE TABLE IF NOT EXISTS person (
operation_ts TIMESTAMP(0) METADATA FROM ‘op_ts’ VIRTUAL,
id INT NOT NULL
,name STRING
,birthday DATE
,PRIMARY KEY ( id ) NOT ENFORCED
) WITH (
‘connector’ = ‘tidb-cdc’
,‘pd-addresses’ = ‘xxx:2379,xxx:2379,xxxx:2379’
,‘scan.startup.mode’ = ‘initial’
,‘tikv.grpc.timeout_in_ms’ = ‘30000’
,‘tikv.grpc.scan_timeout_in_ms’ = ‘30000’
,‘tikv.batch_get_concurrency’ = ‘2000’
,‘server-time-zone’ = ‘Asia/Shanghai’
,‘database-name’ = ‘testdb’
,‘table-name’ = ‘person’
);
select * from person;
