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

在Flink CDC中目前支持整库同步的sink端有哪些?

在Flink CDC中目前支持整库同步的sink端有哪些?

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

在Flink CDC中sink的这3个参数,只要满足其中1个就会触发sink吗?

在Flink CDC中sink的这3个参数,只要满足其中1个就会触发sink,还是3个都要满足了才能sink?请参考图片:

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

在Flink CDC中在pipeline的sink端 如下所示对吗?

在Flink CDC中在pipeline的sink端 table.properties.consumer.mode:at-least-once 就可以了对吗 ?请参考图片:

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

flink cdc当sink开启多个parallel tasks后,是否考虑默认加一个机制?

flink cdc当sink开启多个parallel tasks后,sink表数据和source表数据不一致。如果恢复为单个task后,sink和source表数据是一致的。如果对key做hash,且key足够分散,数据倾斜会好点。不过这是flink function机制,flink cdc是否考虑默认加一个key selector的机制?

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

flink cdc如果因为外部问题导致一个sink执行失败了然后我进入重试。新的流量会被阻塞在哪里?

flink cdc如果因为外部问题导致一个sink执行失败了,然后我进入重试。新的流量会被阻塞在哪里?新的数据是不是还是会被读进来,还是他被阻塞在数据库那边,等我有空间了再读

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

flink cdc pipeline source和sink 做过了怎么办?

flink cdc pipeline source和sink 做过了,由于flink kafka sink 不支持schema event,目前是是直接把schema event 直接json 存储写入kafka,且在Data change event 的kafka header 头重添加了 schema 信息?

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

flink cdc可以sink 到hive嘛报错不支持update呢?

flink cdc可以sink 到hive嘛报错不支持update呢?

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

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

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

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

Flink CDC里如果sink库要换库名只能用route吗?有没有专门指定sink库的库名配置 ?

Flink CDC里如果sink库要换库名只能用route吗?有没有专门指定sink库的库名配置 database.mapping这种?

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

Flink CDC里遇到过SInk到Kafka的这个报错么?

Flink CDC里遇到过SInk到Kafka的这个报错么:Caused by: org.apache.kafka.common.errors.TimeoutException: Topic XXX not present in metadata after 60000 ms.

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

产品推荐

阿里云实时计算Flink

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

+关注