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

Flink如何恢复之前暂停某个流式作业？

提问者：帅平问题分类：大数据

Flink

发布于：4个月前 (12-20) IP属地：四川省

1 个回答

自沧桑

设置变量，重新执行即可，例如：

#设置流模式
SET 'execution.runtime-mode' = 'streaming';
#设置上一次的保存点
SET 'execution.savepoint.path' = <savepointPath>;
#重新执行sql
INSERT INTO table SELECT id,name,age FROM table1;

发布于：4个月前 (12-20) IP属地：四川省

我来回答