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属地:四川省
我来回答
您需要 登录 后回答此问题!