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

Flink CDC 读取mysq出现问题从检查点重启这个flinkcdc任务也不行,如何解决问题?

Flink CDC 读取mysql,出现这个题后,从检查点重启这个flinkcdc任务也不行,请问下可以如何解决这个问题?

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

请问各位,怎么可以实现flink重启后自动恢复正在运行的job任务?

请问各位大佬,flink重启后,正在运行的job和历史job记录都没有了,怎么可以实现flink重启后自动恢复正在运行的job任务?

文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之从检查点重启任务,怎么在YAML配置文件中添加检查点的路径

问题一:使用flink native k8s的nodeport模式,能指定暴露的port吗? 使用flink native k8s的nodeport模式,能指定暴露的port吗? 参考答案: 在Flink中,通过使用NodePort模式暴露服务,可以指定要暴露的端口。NodePort模式允许你将Flink服务从集群内部访问扩展到集群外部,通过为每个节点...

实时计算 Flink版产品使用问题之从检查点重启任务,怎么在YAML配置文件中添加检查点的路径
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之集群重启后,所有的Jobs任务丢失,如何快速恢复

问题一:mysql Flink CDC获取增量数据的时候,速度追不上最新的binlog,有什么解决办法嘛? mysql Flink CDC获取增量数据的时候,速度追不上最新的binlog,这个有什么解决办法嘛? 参考答案: 您好,MySQL Flink CDC获取增量数据时,如果速度追不上最新的binlog,可以尝试以下方法: 全量...

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

在Flink CDC中 抽取数据 凌晨失败了 白天重启任务 它还从之前零点失败时候的点位开始消费?

在Flink CDC中 抽取数据 凌晨失败了 白天重启任务 它还从之前零点失败时候的点位开始消费?

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

Flink在HA模式,重启ZK集群,客户端任务提交异常(疑似脑裂)

基本信息 Flink 1.11.6版本,Standalone HA模式, 滚动重启了ZK集群在Flink集群的一个节点上使用flink run 命令提交多个任务 异常现象 部分任务提交失败,异常信息如下 [Flink-DispatcherRestEndpoint-thread-2] - [WARN ] - [org.apache.flink.runtime.rpc.akka.AkkaInvoc.....

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

Flink CDC如何做到不重启flink任务,监听到table_3表呢?

Flink CDC同步任务 监听mysql 表 table_*mysql中已存在table_1 table_2表,这俩张表数据同步没问题mysql中新增表table_3,如何做到不重启flink任务,监听到table_3表呢?不重启flink cdc任务,监听新创建的表 binlog呢

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

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

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

问答 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....

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何实现重启后直接跑最新的任务而不是根据checkpoint跑历史数据

问题一:这种场景阿里云flink引擎有计划吗? flink 去 lookup join 一张实时写入的维表,在join不到情况下,加入缓存,然后delay retry。这种场景阿里云flink引擎有计划吗? 参考答案: 阿里云Flink引擎确实提供了一些功能来支持维表join操作的优化,但关于特定场景下“实时写入的维表在join不到时加入缓存并延迟重试...

实时计算 Flink版产品使用问题之如何实现重启后直接跑最新的任务而不是根据checkpoint跑历史数据

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

产品推荐

阿里云实时计算Flink

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

+关注