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

Flink这个异常历史, 怎么控制, 每次重启job的时候,不要被删掉了?

Flink这个异常历史, 怎么控制, 每次重启job的时候,不要被删掉了?

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

实时计算Flink作业异常重启

实时计算Flink作业异常重启

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

FLINK SQL 遇到这种异常,一直重启,这种异常怎么处理啊,跳过去?

FLINK SQL 遇到这种异常,一直重启,这种异常怎么处理啊,跳过去?

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

FLINK SQL CDC 遇到这种异常,一直重启,这种异常怎么处理啊,跳过去?

FLINK SQL CDC 遇到这种异常,一直重启,这种异常怎么处理啊?

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

Flink为什么我的这个任务,遇到异常数据自动重启时,不会从上一次的CheckPoint进行重启呢?

Flink为什么我的这个任务,遇到异常数据(手动造了一条)自动重启时,不会从上一次的CheckPoint进行重启呢?而是从latest-offset进行重启呢?手动造了一条异常数据 让它自动重启的。

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

请问下Flink CDC大佬们Dinky异常状态和重启中状态有什么区别?

请问下Flink CDC大佬们Dinky异常状态和重启中状态有什么区别?

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

Flink这种错误是什么原因 会异常重启?

Flink这种错误是什么原因 会异常重启?

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

我想问问:flink sql提交的任务如何持久化,即当flink集群遭遇异常重启后,能够 自动 按c

我想问问:flink sql提交的任务如何持久化,即当flink集群遭遇异常重启后,能够 自动 按checkpoint或savepoint恢复以前的执行任务?flink配置能实现吗?

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

flink cdc运行了一段时间,一直报异常重启,有什么好的解决方案吗?

flink cdc,运行了一段时间,上游数据 某个字段格式出现不匹配记录 sink不到下游,一直报异常 重启,手动将上游该条记录删除后,问题没有解决,然后checkpoint 成功失败都有。这种情况 有什么好的解决方案吗,还是直接cancel 然后重启这个job 呢?

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

大佬们,flink读kafka,序列化时候一旦格式错误报异常,算子就会重启,重启后继续报异常,就反复

大佬们,flink读kafka,序列化时候一旦格式错误报异常,算子就会重启,重启后继续报异常,就反复重启,这种情况你们都怎么处理的?怎么能跳过这一条?

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

产品推荐

阿里云实时计算Flink

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

+关注