全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

解释如何从外部存储系统的故障中恢复FlinkSQL作业

提问者：帅平问题分类：面试刷题

FlinkSQL面试题 Flink

发布于：1周前 (05-29) IP属地：

2 个回答

别活的像别人

具体的措施有：
1、配置启用checkpoint

-- 启用Checkpoint，设置间隔和超时时间
SET 'execution.checkpointing.interval' = '5min';
SET 'execution.checkpointing.timeout' = '10min';
SET 'execution.checkpointing.mode' = 'exactly-once'; -- 或 'at-least-once'

2、手动出发savepoint

# 在维护或升级前主动保存状态
bin/flink savepoint <jobId> [targetDir]

发布于：1周前 (05-29) IP属地：

缝完心脏、一个人活

如果涉及到类似kafka这些支持重试的外部连接器，需要配置restart-strategy

SET 'restart-strategy.fixed-delay.attempts' = '5';
SET 'restart-strategy.fixed-delay.delay' = '10s';

发布于：1周前 (05-29) IP属地：

我来回答