问答 2024-04-15 来自:开发者社区

flink cdc3.0 MySQL同步到Doris。看文档要编写yaml,后续同步任务添加怎么办?

flink cdc3.0 MySQL同步到Doris。看文档要编写yaml,那后续同步任务需要添加同步表怎么处理啊?

问答 2024-04-15 来自:开发者社区

请问 flink cdc3.0 支持 flink1.19 吗?

请问 flink cdc3.0 支持 flink1.19 吗?

问答 2024-04-03 来自:开发者社区

flink cdc3.0 中 mysql -> starRocks 中建表失败,排查到是主键类型问题

flink cdc3.0 中 mysql -> starRocks 中,mysql的主键是cahr类型,但是starRocks中的char类型不支持做主键模型。该怎么解决?

问答 2024-03-25 来自:开发者社区

flink cdc3.0 mysql-starrocks,starrocks的库能否自己指定?

flink cdc3.0 mysql-starrocks,starrocks的库能否自己指定呢?

问答 2024-03-14 来自:开发者社区

Flink cdc3.0 支持变化的表和多张维表 join 了吗?

Flink cdc3.0 支持变化的表和多张维表 join 了吗?

问答 2024-03-14 来自:开发者社区

Flink CDC3.0增量读取source时候,sink可以根据并行度生效,可以做到这个效果不?

Flink CDC3.0增量读取source时候,sink可以根据并行度生效,以表单位或者其他特性分发到其他taskmanager了吗?

问答 2024-03-11 来自:开发者社区

flink cdc3.0整库同步 这里能否是指定库下面的指定表 ? 这里应该怎么写配置呀?

flink cdc3.0整库同步 这里能否是指定库下面的指定表 ? 这里应该怎么写配置呀?

问答 2024-03-06 来自:开发者社区

Flink CDC3.0 MySQL抽数到Doris,要支持字段变更的话,就只能整库同步吗?

Flink CDC3.0 MySQL抽数到Doris,要支持字段变更的话,就只能整库同步(tables: db_name..)吗?我现在是tables参数写了个正则(tables: db_name.table_nameprefix.)来匹配我需要的几张表,作业可以正常运行。但是今天发现当其它表(正则匹配之外的表)有新增字段的时候,会导致我上面的作业报错:Caused by: java.util.....

问答 2024-03-05 来自:开发者社区

Flink CDC3.0 是不是有bug,会报错?

Flink CDC3.0 是不是有bug,会报错? Caused by: com.github.shyiko.mysql.binlog.event.deserialization.MissingTableMapEventException: No TableMapEventData has been found for table id:73090. Usually that means tha....

问答 2024-02-26 来自:开发者社区

Flink CDC里我参照官网CDC3.0案例,MySQL整库同步到Doris怎么做?

我正在尝试使用 Flink CDC 3.0 按照官网案例同步 MySQL 数据库到 Doris,使用的是以下命令:bash bin/flink-cdc.sh mysql-to-doris.yaml,有人说对于新增加的表,可以通过创建 Savepoint 后再从 Savepoint 重新启动作业。我的问题是,具体怎样使用 flink-cdc.sh 脚本从 Savepoint 重启这样的 CDC 作....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注