有没有使用flink cdc把整库使用pipeline同步到starrocks的案例?

提问者:帅平 问题分类:大数据
有没有使用flink cdc把整库使用pipeline同步到starrocks的案例?
2 个回答
为什么放弃治疗
为什么放弃治疗
有的,示例如下:
SET 'execution.checkpointing.interval' = '10s';
EXECUTE PIPELINE WITHYAML (
source:
  type: mysql
  hostname: xxxx
  port: 3306
  username: root
  password: 'xxx!'
  tables: test.t_user,test.t_teacher
  server-id: 5400-5404
 
sink:
  type: starrocks
  name: Starrocks Sink
  jdbc-url: jdbc:mysql://ip:9030
  load-url: ip:8029
  username: root
  password: 'xxxx'
  table.create.properties.replication_num: 1
  table.create.properties.fast_schema_evolution: true 
route:
  - source-table: test.t_user
    sink-table: starrocks_test.t_user 
  - source-table: test.t_teacher
    sink-table: starrocks_test.teacher     
pipeline:
  name: Sync MySQL Database to starrocks Route
  parallelism: 1
)
发布于:6个月前 (12-26) IP属地:四川省
对的时间对的人
对的时间对的人
需要的jar包有:
mysql-connector-java-8.0.30.jar
flink-sql-connector-mysql-cdc-3.2.1.jar
flink-connector-starrocks-1.2.10_flink-1.19.jar
flink-cdc-pipeline-connector-starrocks-3.2.1.jar
flink-cdc-pipeline-connector-mysql-3.2.1.jar
flink-cdc-dist-new.3.2.1.jarflink-cdc-pipeline-connector-paimon-3.2.1.jar
发布于:6个月前 (12-26) IP属地:四川省
我来回答