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

在Flink CDC中一个job节点 两个task节点,数量能设置为更多吗 ?

在Flink CDC中一个job节点 两个task节点 taskmanager.numberOfTaskSlots: 30 数量能设置为更多吗 ?请参考图片:

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

Flink CDC从mysql到doris,Flink Job提交后,数据会立即同步这个会是啥原因?

Flink CDC从mysql到doris,Flink Job提交后,数据会立即同步,后面mysql增量数据不同步,这个会是啥原因?

基于阿里云Hologres&Flink实时计算平台搭建数据仓库(实时)

23 课时 |
322 人已学 |
免费

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
955 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
518 人已学 |
免费
开发者课程背景图
问答 2024-07-02 来自:开发者社区

对于Flink CDC,CDC运行过程中,新增一张需要同步的表,重新提交job后,新增的表会全量?

对于Flink CDC,CDC运行过程中,新增一张需要同步的表,重新提交job后,只有新增的表会全量同步?,其它表增量同步 ?

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

在Flink CDC中flink job mysql->kafka为啥管理界面看不到记录处理条数?

在Flink CDC中flink job mysql->kafka为啥管理界面看不到记录处理条数?请参考图片:

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

我按照Flink CDC 文档操作,提交mysql到doris Job时提示这个,如何解决?

我按照Flink CDC 文档操作,提交mysql到doris Job时提示这个,如何解决?“Exception in thread "main" java.lang.RuntimeException: Cannot find factory with identifier "mysql" in the classpath”

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

在Flink CDC中100%复现,重启任务没用,Job Manager的日志如图1,是什么原因?

在Flink CDC中100%复现,重启任务没用,Job Manager的日志如图1,是什么原因?

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

Flink CDC里job从保存点恢复或者cancel后再提交,元空间一直涨最后oom这个问题怎么办

Flink CDC里job从保存点恢复或者cancel后再提交,元空间一直涨最后oom这个问题如何解决呢?

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

Flink CDC 1.13.6的10个 job脚本运行都没问题,移动另一台配置一样的服务器吗?

Flink CDC 1.13.6的10个 job脚本运行都没问题,移动另一台配置一样的服务器?但flink版本是1.16.0或者 1.17.1 它就跑不了这么多job 第三第四个job开始,可能就卡得一逼了,又没报什么错,就是不知道为什么,conf下的配置也是一样的

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

Flink CDC里mysql cdc 3.0.1 canel job后两个连接没释放有人遇到过吗?

Flink CDC里mysql cdc 3.0.1 canel job后有两个连接没释放有人遇到过吗,默认8小时wait-timeout,多次提交 canel后就把连接撑满了。

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

flink cdc 使用阿里云oss做savepoint,job不运行怎么办?

flink cdc 使用阿里云oss做savepoint,目前flink-conf.yaml配置了oss的配置,jar包也添加了,但是job就起不来了怎么办?

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

实时计算 Flink版cdc相关内容

实时计算 Flink版更多cdc相关

产品推荐

阿里云实时计算Flink

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

+关注