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

在Flink CDC中mysql cdc 使用DS 正则动态增加表还需要重启flink任务才可以吗?

在Flink CDC中mysql cdc 使用DS 正则动态增加表还需要重启flink任务才可以吗?

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

在Flink CDC中任务重启,从checkpoint恢复数据,binlog也存在,就是读取不到如何

在Flink CDC中任务重启,从checkpoint恢复数据,binlog也存在,就是读取不到如何解决?Caused by: java.lang.IllegalStateException: The connector is trying to read binlog starting at Struct{version=1.9.7.Final,connector=mysql,name=mys....

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

在Flink CDC中我往kafka push一条消息,为什么任务A和B都消费到这条数据了呢?

在Flink CDC中kafka做为sink时,用DDL的方式,指定properties.group.id='abc',建两个一模一样的采集任务A和B,同样的sink,这个时候我往kafka push一条消息,为什么任务A和B都消费到这条数据了呢?

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

在Flink CDC中任务运行几天之后突然出现了这个问题,如何解决?

在Flink CDC中任务运行几天之后突然出现了这个问题,如何解决?Caused by: java.lang.NoClassDefFoundError: com/ververica/cdc/common/utils/StringUtils

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

Flink综合判断这个任务资源分配是否合理并给出建议?

Flink现在市面上或者大家公司内部有没有那种智能分析调优工具 比如检查任务状态大小 tm slot数量 内存分配大小 综合判断这个任务资源分配是否合理并给出建议?

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

flink-cdc执行任务找不到ExecutionConfig类,是没有装hadoop导致的吗

2024-06-20 16:47:09,090 INFO [XNIO-1 task-1] o.a.f.r.s.t.h.HadoopFSDelegationTokenProvider [HadoopFSDelegationTokenProvider.java : 76] Hadoop FS is not available (not packaged with this application):....

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

Flink任务提交后出现这个异常要怎么处理呀 ?

Flink任务提交后出现这个异常要怎么处理呀 ?

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

flink任务重启时 指定从6月5号某时开始执行,但数据看不到这段时间的是怎么回事?

flink任务重启时 指定从6月5号某时开始执行,但数据看不到这段时间的是怎么回事?

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

在阿里云全托管flink平台部署jar任务总是报错,如何解决?

在阿里云全托管flink平台部署jar任务总是报错,如何解决?Class conflicts, detailed context: ClassNotFoundException: com.aliyun.tea.TeaException

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

在Flink CDC中重启任务时报了这个错,有一个表的binlog日志不存在,如何还能让任务正常跑?

在Flink CDC中重启任务时报了这个错,有一个表的binlog日志不存在了,如何还能让任务正常跑?Caused by: java.lang.IllegalStateException: The connector is trying to read binlog starting at Struct{version=1.9.7.Final,connector=mysql,name=mysql....

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

产品推荐

实时计算 Flink

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

+关注