问答 2023-10-31 来自:开发者社区

Flink CDC中job一直重启导致 所有剩余task slot =0 ,这个可有办法解决呢?

Flink CDC中job一直重启导致 所有剩余task slot =0 ,这个可有办法解决呢?我是单机启动的,jobmanager taskmanager都在一台机器上啊

问答 2023-10-23 来自:开发者社区

Flink CDC业务系统频繁刷数,cdc有办法做过滤吗?

Flink CDC业务系统频繁刷数,cdc有办法做过滤吗?比如业务系统要刷历史数据,数据量很大。cdc在同步的时候我这里是写kafka,存在瓶颈,而且刷数对我下游是不需要用到的。

问答 2023-10-18 来自:开发者社区

Flink CDC 源表数据删了。结果表有什么办法也同步删除?

Flink CDC 源表数据删了。结果表有什么办法也同步删除?用的Flink SQL来执行INSERT INTO ====

问答 2023-10-18 来自:开发者社区

Flink CDC流式写入doris的时候,遇到有脏数据导致任务直接faild,有没有办法处理?

Flink CDC流式写入doris的时候,遇到有脏数据导致任务直接faild,有没有办法处理?

问答 2023-10-18 来自:开发者社区

Flink CDC对于sqlserver数据结构发生改变,有什么应对办法吗?

Flink CDC对于sqlserver数据结构发生改变,有什么应对办法吗?

问答 2023-10-10 来自:开发者社区

Flink CDC插入hudi的性能100万条,需要5分钟的样子,有没有办法优化呀,并行度4?

Flink CDC插入hudi的性能100万条,需要5分钟的样子,有没有办法优化呀,并行度4?

问答 2023-10-04 来自:开发者社区

Flink CDC这种情况有办法提高同步的速率让不同分片同步过来的数据都是最近几分钟更新的吗?

Flink CDC中mongodb同步数据,有个集合有多个分片,现在发现不同分片数据量不一样,同步到的数据有部分是刚更新的,有部分是几个小时前更新的。这种情况有办法提高同步的速率让不同分片同步过来的数据都是最近几分钟更新的吗?

问答 2023-10-03 来自:开发者社区

Flink CDC使用oraclecdc同步到kafka在快照阶段就发生了oom 有什么办法解决嘛?

Flink CDC使用oraclecdc同步到kafka 在快照阶段就发生了oom 有什么办法解决嘛 taskmanager内存给的是18g?这个是sql的参数

问答 2023-09-28 来自:开发者社区

Flink CDC读取mysql整库, 数据量大了有办法提升读取效率吗? 增量并行度只能1吧?

Flink CDC读取mysql整库, 数据量大了有办法提升读取效率吗? 增量并行度只能1吧?

问答 2023-09-27 来自:开发者社区

Flink CDC的时候有没有办法取到source表的metadata?

Flink CDC的时候有没有办法取到source表的metadata?

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

产品推荐

实时计算 Flink

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

+关注