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

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

Flink CDC在使用MysqlCDC的时候保存savepoint之后重启,程序抛出异常?

Flink CDC在使用MysqlCDC的时候保存savepoint之后重启,程序抛出异常?the first event offset 大于了 end event offset

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

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启?

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启,这是正常日志?

问答 2022-08-03 来自:开发者社区

大佬们,我这flink老重启,然后看异常,就报个空指针,也不知道哪里错了,这种问题咋整

大佬们,我这flink老重启,然后看异常,就报个空指针,也不知道哪里错了,这种问题咋整

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

产品推荐

阿里云实时计算Flink

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

+关注