【详述】https://nightlies.apache.org/flink/flink-cdc-docs-release-3.2/zh/docs/get-started/quickstart/mysql-to-starrocks/,参考这篇文章,我这边配置了mysql同步至starrocks
配置文件如下:
source:
type: mysql
name: MySQL Source
hostname: x.x.x.x
port: 3306
username: dts_user
password: xxx
tables: test..*
server-id: 5401-5404
sink:
type: starrocks
name: StarRocks Sink
jdbc-url: jdbc:mysql://x.x.x.x:9030
load-url: x.x.x.x:8030
username: dts_user
password: xxx
pipeline:
name: Sync MySQL Database to StarRocks
schema.change.behavior: evolve
parallelism: 2
目前的问题是:开启cdc同步后,mysql test库下的所有表及数据可以成功同步至starrocks。然后继续在mysql test库中新建表A,表A没有同步至starrocks,也没有报错信息。请问这是不支持新建表同步吗?
【是否存算分离】否
【StarRocks版本】3.1.15
【集群规模】3fe(1 leader + 2 follower)+ 3be(fe与be独立部署)
【导入或者导出方式】flink 1.18 ,flink cdc 3.1.0
【联系方式】社区群24 - Hanson