2 个回答
示例如下:
EXECUTE CDCSOURCE dinky_paimon_test
WITH
(
'connector' = 'mysql-cdc',
'hostname' = 'ip',
'port' = '3306',
'username' = 'root',
'password' = 'xxx',
'checkpoint' = '10000',
'parallelism' = '2',
'scan.startup.mode' = 'initial',
'database-name' = 'lzs-ad',
'table-name' = 'lzs-ad\.t_report',
'server-id'='5400-5499',
'sink.connector' = 'paimon',
'sink.path' = 'hdfs://mycluster/user/data/paimon/#{schemaName}.db/#{tableName}',
'sink.auto-create' = 'true',
'sink.bucket'='4'
);
发布于:4个月前 (12-26) IP属地:四川省
需要的jar包有:
flink-sql-connector-mysql-cdc-3.2.1.jar
mysql-connector-java-8.0.30.jar
paimon-flink-1.19-0.9.0.jar
flink-shaded-hadoop-2-uber-2.8.3-10.0.jar
flink-cdc-dist-3.2.1.jar
发布于:4个月前 (12-26) IP属地:四川省
我来回答
您需要 登录 后回答此问题!