技术频道

公众号推荐

微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

从0到1Flink的成长之路(二十)-Flink 高级特性二之状态恢复和重启策略

时间：2022-09-04分类：Flink作者：编程之家原文地址

状态恢复和重启策略

在这里插入图片描述

手动重启并恢复
1.把程序打包

在这里插入图片描述

2.启动Flink集群(本地单机版，集群版都可以)

/export/server/flink/bin/start-cluster.sh

3.访问webUI

http://node1.itcast.cn:8081/#/overview

4.使用FlinkWebUI提交

cn.itcast.flink.checkpoint.StreamCheckpointDemo
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint

在这里插入图片描述

5.取消任务

在这里插入图片描述

6.重新启动任务并指定从哪恢复

cn.itcast.flink.checkpoint.StreamCheckpointDemo
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint/aedbaa962fc720954651d27d95fcb53f/chk-106

在这里插入图片描述

7.最后关闭/取消任务

在这里插入图片描述

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

上一篇：【Flink】Flink 的 slotSharingGro 下一篇：Flink从集合中读取数据并且输出出来

相关推荐

Flink-core小总结

Flink-core小总结1.实时计算和离线计算1.1离线计算离线计算的处理数据是固定的离线计算是有延时的，T+1离线计算是数据处理完输出结果，只是输出最终结果离线计算相对可以处理复杂的计算1.2实时计算实时计算是实时的处理数据，数据从流入到计算出结果延迟低实时计算是输

作者：编程之家时间：2022-10-13

开源项目丨Taier1.2版本发布，新增工作流、租户绑定简化等多项功能

2022年7月26日，Taier1.2版本正式发布！本次版本发布更新功能：新增工作流新增OceanBaseSQL新增Flinkjar任务数据同步、实时采集支持脏数据管理HiveUDF控制台UI升级租户绑定简化新版本的使用文档已在社区中推送，大家可以随时下载查阅，欢迎大家体验新版本功能

作者：编程之家时间：2022-10-13

Flink Java DemoWindows

关于Flink相关的概念性东西就不说了，网上都有，官网也很详尽。本文主要记录一下Java使用Flink的简单例子。首先，去官网下载Flink的zip包（链接就不提供了，你已经是个成熟的程序员了，该有一定的搜索能力了），解压后放到你想放的地方。进入主目录后，是这样子的 image.png你可以简

作者：编程之家时间：2022-09-04

Flink window二翻译官方文档

最近准备用flink对之前项目进行重构，这是一个有挑战（但我很喜欢）的工作。几个月过去了，flink社区比起我做技术调研那阵发生了很多变化（包括blink的版本回推），我这边的版本也由1.4->1.7.2。现在网上有很多大方向的解析（阿里的几次直播），也有大神对框架的深入解析。我准备实际使用中mark一些

作者：编程之家时间：2022-09-04

Flink监控：Monitoring Apache Flink Applications

Thispostoriginallyappearedonthe ApacheFlinkblog.Itwasreproducedhereunderthe ApacheLicense,Version2.0.ThisblogpostprovidesanintroductiontoApacheFlink’sbuilt-inmonitoringandmetricssystem,thatallowsdeveloperstoeffectively

作者：编程之家时间：2022-09-04

flink-conf.yaml

Flink配置文件对于管理员来说，差不多经常调整的就只有conf下的flink-conf.yaml：经过初步的调整，大约有以下模块的参数（未优化）LicensedtotheApacheSoftwareFoundation(ASF)underoneormorecontributorlicenseagreements.SeetheNOTICEfiledistributedwiththis

作者：编程之家时间：2022-09-04

flink入门：01 构建简单运行程序

1.mac平台安装flink（默认最新版）brewinstallapache-flink安装结果：Version1.7.1,commitID:89eafb42.jdk版本，我尝试使用了Java8和Java11，都能兼容3.在flink的安装目录下，启动flink目录一般默认在/usr/local/Cellar/apache-flink/1.7.1/（查找flink安装目录：find/-name

作者：编程之家时间：2022-09-04

基于Flink流处理的动态实时电商实时分析系统视频教程

课程目标：学完该课程大家会对Flink有非常深入的了解，同时可以体会到Flink的强大之处，以及可以结合自己公司的业务进行使用，减少自己研究和学习Flink的时间。适合人群：适合有大数据开发基础和flink基础的同学。在开始学习前给大家说下什么是Flink？ 1.Flink是一个针对流数据和批数据的

作者：编程之家时间：2022-09-04

聊聊flink的NetworkEnvironmentConfiguration

本文主要研究一下flink的NetworkEnvironmentConfigurationNetworkEnvironmentConfigurationflink-1.7.2/flink-runtime/src/main/java/org/apache/flinkuntimeaskmanager/NetworkEnvironmentConfiguration.javapublicclassNetworkEnvironmentCon

作者：编程之家时间：2022-09-04

Flink应用案例：How Trackunit leverages Flink to process real-time data from industrial IoT devices

January22,2019 UseCases, ApacheFlinkLasseNedergaard Recentlytherehasbeensignificantdiscussionaboutedgecomputingasamajortechnologytrendin2019.Edgecomputingbrings computingcapabilitiesawayfromthecloud,andrathercloset

作者：编程之家时间：2022-09-04

小编推荐

苹果市值2025年有望达4万亿美元