文章 2024-08-26 来自:开发者社区

美团 Flink 大作业部署问题之根据已存在的 Checkpoint 副本进行增量的副本制作如何实现

问题一:如何根据已存在的 Checkpoint 副本进行增量的副本制作? 如何根据已存在的 Checkpoint 副本进行增量的副本制作? 参考回答: 进行增量的副本制作时,首先解析出新 Checkpoint 和旧 Checkpoint 的文件列表,通过集合运算找出新增的文件(只存在于新 Checkpoint 中的文件)和需要删除的文件(只存在于旧 C...

美团 Flink 大作业部署问题之根据已存在的 Checkpoint 副本进行增量的副本制作如何实现
文章 2024-08-26 来自:开发者社区

美团 Flink 大作业部署问题之Checkpoint Replicate Service 跨 HDFS 集群的副本制作是如何实现的

问题一:为什么使用 distcp 跨机房复制 Checkpoint 不是一个好的选择? 为什么使用 distcp 跨机房复制 Checkpoint 不是一个好的选择? 参考回答: 使用 distcp 跨机房复制 Checkpoint 不是一个好的选择,因为 distcp 会为每个复制任务启动一个重的 mapreduce 作业,而 Checkpoint ...

美团 Flink 大作业部署问题之Checkpoint Replicate Service 跨 HDFS 集群的副本制作是如何实现的
文章 2024-08-26 来自:开发者社区

美团 Flink 大作业部署问题之新启动作业的 Checkpoint 跨作业文件引用的问题要如何避免

问题一:制作 Checkpoint5 时如何知道 02.sst 和 03.sst 已经上传过了? 制作 Checkpoint5 时如何知道 02.sst 和 03.sst 已经上传过了? 参考回答: 制作 Checkpoint5 时,通过 previous-sst-list 来记录上次成功的 Checkpoint 中所有 SST 文件信息,从而知道 0...

美团 Flink 大作业部署问题之新启动作业的 Checkpoint 跨作业文件引用的问题要如何避免
文章 2024-08-26 来自:开发者社区

美团 Flink 大作业部署问题之RocksDBStateBackend 的增量 Checkpoint 要怎么制作

问题一:如何避免跨存储系统 Checkpoint 副本不可用的问题? 如何避免跨存储系统 Checkpoint 副本不可用的问题? 参考回答: 要避免跨存储系统 Checkpoint 副本不可用的问题,可以将所有被直接和间接引用的文件都复制到新的存储系统上。但这会极大增加副本制作的复杂度。 关于本问题的更多回答可点击原文查看: ...

美团 Flink 大作业部署问题之RocksDBStateBackend 的增量 Checkpoint 要怎么制作
文章 2024-08-26 来自:开发者社区

美团 Flink 大作业部署问题之 Checkpoint 跨机房副本的制作能力如何实现

问题一:如何实现 Checkpoint 跨机房副本的制作能力? 如何实现 Checkpoint 跨机房副本的制作能力? 参考回答: 实现 Checkpoint 跨机房副本的制作能力,需要实现一个 Checkpoint Replicate Service,该服务负责将 Checkpoint 实时复制到备份机房,以确保 Checkpoint 的跨机房容灾能...

美团 Flink 大作业部署问题之 Checkpoint 跨机房副本的制作能力如何实现
文章 2024-08-26 来自:开发者社区

美团 Flink 大作业部署问题之Checkpoint 的 metadata 文件包含什么信息

问题一:为什么更倾向于使用 Retained Checkpoint 而不是 Savepoint 来重启作业? 为什么更倾向于使用 Retained Checkpoint 而不是 Savepoint 来重启作业? 参考回答: 我们更倾向于使用 Retained Checkpoint 来重启作业,因为使用 RocksDBStateBackend 的增量 C...

美团 Flink 大作业部署问题之Checkpoint 的 metadata 文件包含什么信息
问答 2024-08-21 来自:开发者社区

Flink的jar作业checkpoint需要作业中开启么?还是提交后自动开启

Flink的jar作业checkpoint需要作业中开启么?还是提交后自动开启

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

在 Flink 1.15 中,关于作业结束前的 Checkpoint 有何变化?

在 Flink 1.15 中,关于作业结束前的 Checkpoint 有何变化?

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

字节跳动在晚高峰时Flink作业处理消息的QPS和Checkpoint高峰流量吞吐分别是多少?

字节跳动在晚高峰时Flink作业处理消息的QPS和Checkpoint高峰流量吞吐分别是多少?

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

Flink Python作业Checkpoint慢

Flink Python作业Checkpoint慢

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

产品推荐

实时计算 Flink

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

+关注