文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之如何实现MVSOL同步到Doris,并且源库和目标库的库名不同

问题一:在Flink如果cdc任务 关闭再重启 能保证消费位点的准确性么? 在Flink如果cdc任务 关闭再重启 能保证消费位点的准确性么? 参考答案: 关闭前创建快照,就可以了 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/658100 ...

实时计算 Flink版产品使用问题之如何实现MVSOL同步到Doris,并且源库和目标库的库名不同
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之要将MySQL同步到Doris,并设置整库同步,只变更库名、表名和表结构都不变,该如何设置

问题一:flink cdc现在有哪个版本可以支持sqlserver的整库同步么?没有主键的表能同步么? flink cdc现在有哪个版本可以支持sqlserver的整库同步么?没有主键的表能同步么? 参考答案: mysql的cdc 2.4版本支持无主键表的同步。 关于本问题的更多回答可点击进行查看: https://...

实时计算 Flink版产品使用问题之要将MySQL同步到Doris,并设置整库同步,只变更库名、表名和表结构都不变,该如何设置
问答 2024-07-02 来自:开发者社区

对于Flink CDC,mysql到Doris库的mysql-to-doris.yaml用这个属性嘛

对于Flink CDC,mysql到Doris库的的那个示例mysql-to-doris.yaml可以用这个属性嘛?

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

在Flink CDC中想利用FlinkCDC 做tidb 到doris 的全库同步,只能建立一个吗?

在Flink CDC中想利用FlinkCDC 做tidb 到doris 的全库同步, 是只能每表建一个job么?

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

Flink CDC里pipline doris sink 怎么指定库,文档没看到呢?

Flink CDC里pipline doris sink 怎么指定库,文档没看到呢?我看到 route 了,但是我有几百张表,不能每个表都写 route 吧?

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

Flink CDC里有没有大佬试过cdc3.0.0到doris管道模式全库同步啊?

Flink CDC里有没有大佬试过cdc3.0.0到doris管道模式全库同步。我这边按照git配置后,启用同步脚本报错org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type java.lang.St....

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

Flink CDC 里mysql->Doris的整库同步,没有成功自动建表以及同步数据?

Flink CDC 里java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.SchemaChangeRequest@3d93dee1 mysql->Doris的整库同步,没有成功自动建表以及同步数据?Fli...

问答 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-04 来自:开发者社区

Flink cdc 利用doris整库同步oracle中的数据 应该怎么操作?

Flink cdc 利用doris整库同步oracle中的数据 应该怎么操作?

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

Flink CDC里我在做mysql到doris的整库同步,怎么做到下面这个操作?

Flink CDC里我在做mysql到doris的整库同步,需要把某个表排除,通过debezium.table.exclude.list设置了排除的表名,但没有生效,还是把所有表都同步了,有碰到过类似问题的吗?是不是用法不对?yaml任务文件这么配置的。这个是正向匹配吧?怎么做到反向排除?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注