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

Flink CDC里 初始化全量数据时没问题 增量数据会报错是为什么?

Flink CDC里 初始化全量数据时没问题 增量数据会报错是为什么?

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

Flink CDC里flink消费kafka里的数据,1秒2w条,堆积就十分严重,怎么解决?

Flink CDC里flink消费kafka里的数据,1秒2w条,堆积就十分严重,没什么算子,就是解析cdc的数据直接入doris,有解吗?

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

Flink CDC里我们公司目前要集成oracle 的数据,它的cdc有没有在企业用过啊?

Flink CDC里我们公司目前要集成oracle 的数据,oracle的cdc有没有在企业中使用过啊?有没有什么疑难杂症呢?

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

Flink CDC里我用cdc同步mysql数据到mysql,想增加一个表结构变更的通知,该怎么做?

Flink CDC里我用cdc同步mysql数据到mysql,想增加一个表结构变更的通知,这个该怎么实现呢?有相似的实现吗?

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

Flink CDC里Lookup Join之后,再分组聚合,为什么跑了两天之后有点数据开始从0聚合?

Flink CDC里Lookup Join之后,再分组聚合,为什么跑了两天之后,有点数据开始从0开始聚合了啊?有的数据是正常的,有的数据的清0了,我这边没有设置TTL,状态也会过期吗?

文章 2024-01-27 来自:开发者社区

Flink CDC里我通过oracle的connector往hudi插入数据

Flink CDC里我通过oracle的connector往hudi插入数据,flink web ui里面为啥Sink: clean_commits 这个步骤并行度是1,我设置的默认并行度是5,但是它改变不了为什么? Flink CDC 中,Sink: clean_commits 步骤的并行度是由 Hudi 控制台配置决定的。...

问答 2024-01-24 来自:开发者社区

Flink CDC里为啥我用flink sql从kafka订阅canaljson插入数据删除不了?

Flink CDC里我用flink sql从kafka订阅canaljson插入数据,如果这个数据插入后,重启任务,然后发送canaljson无法删除,不重启的话就可以,为什么?

问答 2024-01-24 来自:开发者社区

Flink CDC里CD C在读mysql数据时,怎么会乱码?

Flink CDC中使用官方示例的JsonDebeziumDeserializationSchema读取MySQL数据时中文乱码,而使用StringDebeziumDeserializationSchema则不会,这是什么原因?

问答 2024-01-24 来自:开发者社区

Flink CDC里sqlserver 可以指定时间戳回拨拉取数据吗?

Flink CDC里sqlserver 可以指定时间戳回拨拉取数据吗?

问答 2024-01-24 来自:开发者社区

Flink CDC里cdc 同步 PG的数据,会对线上业务库性能影响很大么?

Flink CDC里 同步 PG的数据,为了获取 delete/update 操作,需要 [ALTER TABLE reptest REPLICA IDENTITY FULL;] ,业务库需要所有表都同步的话,会对线上业务库性能影响很大么?

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

产品推荐

实时计算 Flink

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

+关注