有没有flink-cdc把数据同步到paimon的案例?

提问者:帅平 问题分类:大数据
有没有flink-cdc把数据同步到paimon的案例?
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属地:四川省
我来回答