问答 2023-07-25 来自:开发者社区

flink 的kafkaSink 如果我kafka突然宕机了 那没有发送成功的数据 flink?

flink 的kafkaSink 如果我kafka突然宕机了 那没有发送成功的数据 flink的kafkaSink是怎么处理的。过期丢弃了还是怎么?kafka 宕机不会引起程序挂掉,所以上游发了数据 程序没有报错停止,但是kafka停了发不出去,直到kafka 恢复 这个数据是怎么处理的,会一直刷失去连接但是不会报错我跑了10分钟,重连确实不会导致任务失败,发送数据失败会引起任务失败

问答 2023-07-13 来自:开发者社区

Flink CDC任务意外宕机了,从检查点开始启动同步!这是从checkpoint启动吗?

Flink CDC任务意外宕机了,从检查点开始启动同步这是从checkpoint启动吗?

问答 2023-06-27 来自:开发者社区

flink Standalone-HA模式,当运行中的taskmanager宕机或被误杀后,

flink Standalone-HA模式,当运行中的taskmanager宕机或被误杀后,导致整个作业挂了。 想问下,有没有办法当taskmanager宕机或被误杀后, JobManager 有没有办法将宕机掉taskmanager,进行重新分配到新的机器上, 保证作业正常运行,而不是让作业挂了

问答 2023-04-26 来自:开发者社区

我看你上面又说会宕机,具体指的是oracle还是flink的?会影响到Oracle吗?

我看你上面又说会宕机,具体指的是oracle还是flink的?会影响到Oracle吗?

问答 2023-02-27 来自:开发者社区

flink cdc yarn application模式的任务,如果服务器宕机的情况下,怎么办?

flink cdc yarn application模式的任务,如果服务器宕机的情况下,该怎么恢复?

问答 2022-11-23 来自:开发者社区

MongoCommandException会导致flink宕机,想请教一下有没有人知道有什么方法解决

com.mongodb.MongoCommandException: Command failed with error 10334 (BSONObjectTooLarge)

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

请教一下各位有没有遇到相同问题的,flink-cdc挂上去两到三个任务flink集群 宕机的情况,怎

请教一下各位有没有遇到相同问题的,flink-cdc挂上去两到三个任务flink集群 宕机的情况,怎么办?

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

flink CDC的作业放上去,放多几个集群就宕机崩了是什么情况.flinkCDC的作业压力跟数据量

flink CDC的作业放上去,放多几个集群就宕机崩了是什么情况.flinkCDC的作业压力跟数据量关系大吗?

文章 2021-12-10 来自:开发者社区

Flink状态管理与Checkpoint实战——模拟电商订单计算过程中宕机的场景,探索宕机恢复时如何精准继续计算订单(下)

public class VideoOrderSourceV2 extends RichParallelSourceFunction<VideoOrder> { private volatile Boolean flag = true; private Random random = new Random(); private static List<V...

Flink状态管理与Checkpoint实战——模拟电商订单计算过程中宕机的场景,探索宕机恢复时如何精准继续计算订单(下)
文章 2021-12-10 来自:开发者社区

Flink状态管理与Checkpoint实战——模拟电商订单计算过程中宕机的场景,探索宕机恢复时如何精准继续计算订单(上)

Flink的状态与容错是这个框架很核心的知识点。其中一致检查点也就是Checkpoints也是Flink故障恢复机制的核心,这篇文章将详细介绍Flink的状态管理和Checkpoints的概念以及在生产环境中的参数设置。什么是State状态?在使用Flink进行窗口聚合统计,排序等操作的时候,数据流的处理离不开状态管理是一个Operator的运行的状态/历史值,在内存中进行维护流程:一个算子的子....

Flink状态管理与Checkpoint实战——模拟电商订单计算过程中宕机的场景,探索宕机恢复时如何精准继续计算订单(上)

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

产品推荐

阿里云实时计算Flink

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

+关注