当前位置：首页 > news >正文

【详细介绍及演示】Flink之checkpoint检查点的使用

news 来源：原创 2025/5/14 12:05:06

一、介绍

二、设置checkpoint检查点演示

1、代码演示

2、测试代码效果

3、查看快照情况

编辑

三、在集群上运行

1、第一次运行

2、第二次运行

四、自定义检查点savePoint

1、提交一个flink job 打成jar包

2、输入一些数据，观察单词对应的数字的变化

编辑 3、执行savepoint操作，添加检查点

4、查看最近完成的flink job对应的savepoint

5、重新启动flink job，进行测试

6、观察变化

五、总结

一、介绍

Checkpoint:快照点, 是Flink中所有有状态的Operator在某一个时刻的State快照信息/存档信息。

一句话概括: Checkpoint就是State的快照。

二、设置checkpoint检查点演示

简单的举例说明：

1、代码演示

package com.bigdata.checkpoint;import org.apache.flink.api.common.RuntimeExecutionMode;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.api.common.time.Time;
import org.apache.flink.api.java.functions.KeySelector;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.runtime.state.filesystem.FsStateBackend;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.CheckpointConfig;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.util.Collector;import java.util.concurrent.TimeUnit;public class CheckPointWordCountDemo {public static void main(String[] args) throws Exception {//1. env-准备环境StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setRuntimeMode(RuntimeExecutionMode.AUTOMATIC);// 在windows运行，将数据提交hdfs,会出现权限问题，使用这个语句解决。System.setProperty("HADOOP_USER_NAME", "root");// 在这个基础之上，添加快照// 第一句：开启快照，每隔1s保存一次快照env.enableCheckpointing(1000);// 第二句：设置快照保存的位置env.setStateBackend(new FsStateBackend("hdfs://bigdata01:9820/flink/checkpoint"));// 第三句： 通过webui的cancel按钮，取消flink的job时，不删除HDFS的checkpoint目录env.getCheckpointConfig().enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);//checkpoint默认重启策略是一直重启,可以自己定义重启策略//重启策略可以单独使用，不设置checkpoint也可使用   //savepoint可以手动使用命令设置checkpoint//2分钟内重启3次，重启时间间隔是5senv.setRestartStrategy(RestartStrategies.failureRateRestart(3,Time.of(2, TimeUnit.MINUTES),Time.of(5,TimeUnit.SECONDS)));//2. source-加载数据DataStreamSource<String> source = env.socketTextStream("localhost", 9999);//3. transformation-数据处理转换source.flatMap(new FlatMapFunction<String, String>() {@Overridepublic void flatMap(String line, Collector<String> collector) throws Exception {String[] arr = line.split(" ");for (String word : arr) {collector.collect(word);}}}).map(new MapFunction<String, Tuple2<String,Integer>>() {@Overridepublic Tuple2<String, Integer> map(String word) throws Exception {return Tuple2.of(word,1);}}).keyBy(new KeySelector<Tuple2<String, Integer>, String>() {@Overridepublic String getKey(Tuple2<String, Integer> tuple2) throws Exception {return tuple2.f0;}}).sum(1).print();//4. sink-数据输出//5. execute-执行env.execute();}
}

2、测试代码效果

首先启动本地的nc，启动hdfs服务

3、查看快照情况

运行，刷新查看checkpoint保存的数据，它会先生成一个新的文件夹，然后再删除老的文件夹，在某一时刻，会出现两个文件夹同时存在的情况。

三、在集群上运行

首先启动flink：start-cluster.sh

由上一步可以发现数据是保存了，但是并没有起作用，想起作用需要在集群上运行，以下演示集群上的效果：

1、第一次运行

在本地先clean, 再package ，再Wagon一下：

在bigdata01服务器上执行以下命令

#flink run -c 全类名 /opt/app/flink-test-1.0-SNAPSHOT.jarflink run -c com.bigdata.day06._01CheckPointDemo /opt/app/FlinkDemo-1.0-SNAPSHOT.jar#记得，先启动nc ,再启动任务，否则报错！

通过nc -lk 9999 输入以下内容：

进入bigdata01:8081页面上查看结果

想查看运行结果，可以通过使用的slot数量判断一下：

取消flink job的运行

查看一下这次的单词统计到哪个数字了：

2、第二次运行

#flink run -c 全类名  -s hdfs://hadoop10:8020/flink-checkpoint/293395ef7e496bda2eddd153a18d5212/chk-34  /opt/app/flink-test-1.0-SNAPSHOT.jar#启动
flink run -c com.bigdata.day06._01CheckPointDemo -s hdfs://bigdata01:9820/flink/checkpoint/bf416df7225b264fc34f8ff7e3746efe/chk-603  /opt/app/FlinkDemo-1.0-SNAPSHOT.jar

-s 指定从checkpoint目录恢复状态数据，注意每个人都不一样

从上一次离开时，截止的checkpoint目录

观察数据：在nc 上输入一个hello,1 得到新的结果hello,8

四、自定义检查点savePoint

checkpoint自动完成state快照、savePoint是手动的完成快照。

如果程序在没有设置checkpoint的情况，可以通过savePoint设置state快照

1、提交一个flink job 打成jar包

package com.bigdata.checkpoint;import org.apache.flink.api.common.RuntimeExecutionMode;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.api.common.time.Time;
import org.apache.flink.api.java.functions.KeySelector;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.runtime.state.filesystem.FsStateBackend;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.CheckpointConfig;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.util.Collector;import java.util.concurrent.TimeUnit;public class CheckPointWordCountDemo {public static void main(String[] args) throws Exception {//1. env-准备环境StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setRuntimeMode(RuntimeExecutionMode.AUTOMATIC);//重启策略可以单独使用，不设置checkpoint也可使用  //savepoint可以手动使用命令设置checkpoint//2分钟内重启3次，重启时间间隔是5senv.setRestartStrategy(RestartStrategies.failureRateRestart(3,Time.of(2, TimeUnit.MINUTES),Time.of(5,TimeUnit.SECONDS)));//2. source-加载数据DataStreamSource<String> source = env.socketTextStream("bigdata01", 2727);//3. transformation-数据处理转换source.flatMap(new FlatMapFunction<String, String>() {@Overridepublic void flatMap(String line, Collector<String> collector) throws Exception {String[] arr = line.split(",");for (String word : arr) {collector.collect(word);}}}).map(new MapFunction<String, Tuple2<String,Integer>>() {@Overridepublic Tuple2<String, Integer> map(String word) throws Exception {//自制一个bug用来测试if(word.equals("bug")){throw new Exception("出错了，请重试");}return Tuple2.of(word,1);}}).keyBy(new KeySelector<Tuple2<String, Integer>, String>() {@Overridepublic String getKey(Tuple2<String, Integer> tuple2) throws Exception {return tuple2.f0;}}).sum(1).print();//4. sink-数据输出//5. execute-执行env.execute();}
}

执行改任务

2、输入一些数据，观察单词对应的数字的变化

3、执行savepoint操作，添加检查点

停止flink job，并且触发savepoint操作

flink stop --savepointPath  hdfs://bigdata01:9820/flink-savepoint  152e493da9cdeb327f6cbbad5a7f8e41

后面的序号为Job 的ID

不会停止flink的job，只是完成savepoint操作(执行这个操作)

flink savepoint 79f53c5c0bb3563b6b6ed3011176c411 hdfs://bigdata01:9820/flink-savepoint

停止一个 flink 的任务

flink stop 6a27b580aa5c6b57766ae6241d9270ce

后面的序号为Job 的ID

4、查看最近完成的flink job对应的savepoint

发现任务中已经有检查点

5、重新启动flink job，进行测试

停止任务后，查看最终检查点的路径

然后重新启动

flink run -c com.bigdata.day06._01CheckPointDemo -s hdfs://bigdata01:9820/flink-savepoint/savepoint-79f53c-64b5d94771eb /opt/app/flink-test-1.0-SNAPSHOT.jar

-c后是全类名，-s 后是检查的路径，最后一部分是jar包的位置

6、观察变化

再次输入单词，可以看到在之前的基础上累加

另外，在集群中运行我们的程序，默认并行度为1，它不会按照机器的CPU核数，而是按照配置文件中的一个默认值运行的

五、总结

有两种添加检查点的方式：

1、在java代码中自动添加

在执行任务时会在hdfs上创建检查点

// 第一句：开启快照，每隔1s保存一次快照
env.enableCheckpointing(1000);
// 第二句：设置快照保存的位置
env.setStateBackend(new FsStateBackend("hdfs://bigdata01:9820/flink/checkpoint"));
// 第三句： 通过webui的cancel按钮，取消flink的job时，不删除HDFS的checkpoint目录env.getCheckpointConfig().enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);

2、在集群上通过命令在指定位置手动添加

flink savepoint 任务号 hdfs://bigdata01:9820/flink-savepoint

【详细介绍及演示】Flink之checkpoint检查点的使用

目录一、介绍二、设置checkpoint检查点演示 1、代码演示 2、测试代码效果 3、查看快照情况编辑三、在集群上运行 1、第一次运行 2、第二次运行四、自定义检查点savePoint 1、提交一个flink job 打成jar包 2、输入一些数据，观察单词对应的数字的…...

编程日记 2025/5/14 12:05:06

使用uni-app进行开发前准备

使用uni-app进行开发，需要遵循一定的步骤和流程。以下是一个详细的指南，帮助你开始使用uni-app进行开发： 一、开发环境搭建安装Node.js： 首先，从Node.js的官方网站（https://nodejs.org/）下载并…...

编程日记 2025/5/14 7:55:58

deepin 安装 chrome 浏览器

deepin 安装 chrome 浏览器最近好多小伙伴儿和我说 deepin 无法安装最新的谷歌浏览器其实是因为最新的谷歌浏览器其中的一个依赖需要提前安装提前安装依赖然后再安装谷歌浏览器就可以了安装 fonts-liberationsudo apt -y install fonts-liberation安装 chrome 浏览器sudo…...

编程日记 2025/5/14 11:50:18

Vue-01

Vue框架 Vue官网： Vue.js 框架数据模型和view的通信就是依靠viewmodel的关键。目前主流版本仍然是vue2版本。 Vue快速入门 1.新建一个HTML文件，引入Vue.js文件。Vue.js文件是官方引入的一个文件，我们如果要使用Vue就必须引入这个文件。…...

编程日记 2025/5/10 10:53:03

【建表】 create table emp( id number(12), name nvarchar2(20), primary key(id) ); 【充值一】 insert into emp select rownum,dbms_random.string(*,dbms_random.value(6,20)) from dual connect by level<101; 【充值二】 begin for i in 1..100 loop inser…...

编程日记 2025/5/14 6:00:09

11.28.2024刷华为OD

文章目录 C-100-5键键盘（extend来加入list后尾）题目2语法知识记录 C-100-5键键盘（extend来加入list后尾） 考虑所有情况extend来加入clip数组内容到screen 【】题目2 链接代码语法知识记录...

编程日记 2025/5/14 11:56:02

【S500无人机】--地面端下载

之前国庆的时候导师批了无人机，我们几个也一起研究了几次，基本把无人机组装方面弄的差不多了，还差个相机搭载，今天我们讲无人机的调试硬件配置如下首先是地面端下载，大家可以选择下载： Mission Planne地…...

编程日记 2025/5/12 2:49:37

Redis2——协议与异步方式

文章目录 Redis2——协议与异步方式1. Redis Pipeline2. Redis事务2.1 无锁事务控制（乐观事务控制）2.2 事务语句与lua脚本2.3 事务特性ACID 3. 通信方式3.1 hiredis库3.2 同步连接3.3 异步连接3.3.1 hiredis管理监听事件接口3.3.2 hiredis libevent3.3.…...

编程日记 2025/5/14 8:43:05

面向下一代技术，遨游通讯如何助力北斗规模化应用提速？

近日，纪念北斗卫星导航系统工程建设三十周年座谈会在北京隆重召开，据悉，我国计划在2035年完成下一代北斗系统的建设。“北斗牵手，守护永久”北斗三号短报文公众应用商用试验启动仪式也于本月在雄安新区举行，会上透露&a…...

编程日记 2025/5/9 17:32:29

vue实现echarts饼图自动轮播

echarts官网：Examples - Apache ECharts echartsFn.ts 把echarts函数封装成一个文件 import * as echarts from "echarts";const seriesData [{"value": 12,"name": "过流报警"},{"value": 102,"name&qu…...

编程日记 2025/5/14 7:56:44

数据分析的尽头是web APP？

数据分析的尽头是web APP？ 在做了一些数据分析的项目，也制作了一些数据分析相关的web APP之后，总结自己的一些想法和大家分享。 1.web APP是呈现数据分析结果的另外一种形式。数据分析常见的结果是数据分析报告，可以是PPT或者…...

编程日记 2025/5/8 16:53:11

windows电脑上安装树莓派操作系统

在Windows电脑上安装树莓派通常涉及以下几个步骤：准备安装工具、下载树莓派系统镜像、烧录系统到SD卡、配置树莓派以及远程连接（如果需要无显示器操作）。以下是详细的步骤说明：一、准备安装工具安装树莓派官方烧录工具：下载并安装Raspberry Pi Imager。这是一个官方的…...

编程日记 2025/5/13 2:31:41

openssl编译安装升级为新版本

文章目录 1、下载版本2、上传并解压3、编译安装4、验证 1、下载版本 https://www.openssl.org/source/old/1.1.1/ 2、上传并解压 tar zxvf openssl-1.1.1s.tar.gz 3、编译安装注意：要提前安装好 gcc perl cd openssl-1.1.1s ./config --prefix/usr/local/open…...

编程日记 2025/5/12 1:58:09

监控视频汇聚平台：Liveweb视频监控管理平台方案详细介绍

Liveweb国标视频综合管理平台是一款以视频为核心的智慧物联应用平台。它基于分布式、负载均衡等流媒体技术进行开发，提供广泛兼容、安全可靠、开放共享的视频综合服务。该平台具备多种功能，包括视频直播、录像、回放、检索、云存储、告警上报、语音对讲、…...

编程日记 2025/5/13 14:00:38

【论文复现】基于BERT的语义分析实现

📝个人主页🌹：Eternity._ 🌹🌹期待您的关注 🌹🌹 ❀ WRN: 宽度残差网络概述语义分类文本分类情感分类实现原理核心逻辑pre_deal.pytrain.pytest_demo.py 实现方式&演示效果训练阶段测试阶…...

编程日记 2025/5/8 12:24:07

SMOTE | 使用SMOTE算法来处理不平衡数据的问题

需求在学习机器学习识别信用卡欺诈交易这个项目的时候，样本数据集非常不平衡： data_df_new[Class].value_counts()0： 正常 1：欺诈在这里了解到了SMOTE算法： 过采样（Oversampling） 过采样是…...

编程日记 2025/5/10 4:58:02

week 9 - Entity-Relationship Modelling

一、数据库设计的重要性 • 设计数据库可使查询更高效、简洁。 • 减少数据冗余（data redundancy），提升表的整洁性。二、Key Components of ER Modelling 实体-关系建模的基本构成 1. 实体（Entity）：表…...

编程日记 2025/5/12 5:54:42

彻底理解如何保证ElasticSearch和数据库数据一致性问题

一.业务场景举例需求： 一个卖房业务，双十一前一天，维护楼盘的运营人员突然接到合作开发商的通知，需要上线一批热门的楼盘列表，上传完成后，C端小程序支持按楼盘的名称、户型、面积等产品属性全模糊搜索热门…...

编程日记 2025/5/10 3:06:54

JS基础知识05-对象、Ajax、JSON

目录一、对象 1.1.对象（Object） 1.创建对象对象的常用方法 1.2.Math对象 1.数学常数 2.数学函数 3.随机数生成 4.对数方法 1.3.Date对象创建Date对象获取日期和时间的方法设置日期和时间的方法日期的格式化方法二、Ajax 1.创建XM…...

编程日记 2025/5/11 20:33:17

pandas 读写excel

在Python中，使用Pandas库读写Excel文件是一个常见的操作。Pandas提供了read_excel和to_excel方法来分别实现读取和写入Excel文件的功能。以下是一些基本的示例： ### 读取Excel文件 python import pandas as pd # 读取Excel文件 df pd.read_excel(pat…...

编程日记 2025/5/11 10:39:33

Windows加固脚本

echo off REM 清屏 cls title 安全策略设置批处理 color f0 echo **************************************** echo write by afei echo https://www.jianshu.com/u/ea4c85fbe8c7 echo **************************************** pause cls color 3f echo ********************…...

编程日记 2025/5/11 15:00:16

28.100ASK_T113-PRO Linux+QT 显示一张照片

1.添加资源文件 2. 主要代码 #include "mainwindow.h" #include "ui_mainwindow.h" #include <QImage> #include <QPixmap>MainWindow::MainWindow(QWidget *parent) :QMainWindow(parent),ui(new Ui::MainWindow) {ui->setupUi(this);QIm…...

编程日记 2025/5/8 3:57:17

Vue中的计算属性和监听属性

在Vue中，计算属性和监听属性是两种非常有用的功能，它们可以帮助我们更好地管理数据和响应数据的变化。计算属性计算属性是基于它们的依赖进行缓存的。只有当依赖发生变化时，计算属性才会重新计算。这使得计算属性非常适合用于执行昂贵的计…...

编程日记 2025/5/12 21:52:03

基于vite创建的react18项目的单元测试

题外话最近一个小伙伴进了字节外包，第一个活就是让他写一个单元测试。嗯，说实话，在今天之前我只知道一些理论，但是并没有实操过，于是我就试验了一下。通过查询资料，大拿们基本都说基于vite的项目&…...

编程日记 2025/5/4 22:06:14

网络——HTTP与HTTPS三次握手和四次挥手

HTTP协议本身并不直接处理TCP连接的建立和关闭，这些是由底层的TCP协议来完成的。但是，由于HTTP通常运行在TCP之上，因此理解TCP的三次握手（用于建立连接）和四次挥手（用于关闭连接）对于理解HTTP通…...

编程日记 2025/5/8 10:02:59

自然语言处理:第六十六章 17 种 prompt engineering 方法大集合

本人项目地址大全：Victor94-king/NLP__ManVictor: CSDN of ManVictor 原文地址：17 种 prompt engineering 方法大集合写在前面: 笔者更新不易，希望走过路过点个关注和赞，笔芯!!! 写在前面: 笔者更新不易，希望走过路…...

编程日记 2025/5/13 17:38:10

MySQL —— MySQL 程序

目录前言一、MySQL 程序简介二、mysqld -- MySQL 服务器三、mysql -- MySQL 客户端 1. mysql 客户端简介 2. mysql 客户端选项 （1）指定选项的方式 （2）mysql 客户端命令常用选项 （3）在命令行中使…...

编程日记 2025/5/5 3:00:12

AI蛋白质设计与人工智能药物设计

AI蛋白质设计与人工智能药物设计 AI蛋白质设计一、蛋白质相关的深度学习简介 1.基础概念 1.1.机器学习简介：从手写数字识别到大语言模型 1.2.蛋白质结构预测与设计回顾 1.3.Linux简介 1.4.代码环境：VS code和Jupyter notebook* 1.5.Python关键概…...

编程日记 2025/5/14 11:44:40

Java基础之控制语句：开启编程逻辑之门

一、Java控制语句概述 Java 中的控制语句主要分为选择结构、循环结构和跳转语句三大类，它们在程序中起着至关重要的作用，能够决定程序的执行流程。选择结构用于根据不同的条件执行不同的代码路径，主要包括 if 语句和 switch 语句。if 语句有…...

编程日记 2025/5/14 11:39:47

安装Fcitx5输入框架和输入法自动部署脚本(来自Mark24)-Ubuntu通用

在Ubuntu22.04上安装rime中文输入法的基本教程上述文章接近废弃。使用新逻辑配置基本的Fcitx5的输入法。安装第一步，下载相关组件 sudo nala install vim sudo nala install ruby sudo nala install fcitx5-rime第二步，设置语言为Fcitx5 而非默认…...

编程日记 2025/5/14 11:50:18

软件无线电(SDR)的架构及相关术语

今天简要介绍实现无线电系统调制和解调的主要方法，这在软件定义无线电(SDR)的背景下很重要。外差和超外差无线电发射机有两种主要架构——一种是从基带频率直接调制到射频频率（称为外差），而第二种超外差是通过两个调制阶段来实…...

编程日记 2025/5/14 11:43:27

刷题分享11_30

刷题分享 1.(力扣216)这是一道回溯算法的经典题目。对于回溯算法，一般backtracking是没有返回值的，参数也比较不固定，需要根据每个题的特点来具体分析。这道题因为不能取到重复元素，所以需要额外加一个参数startindex，…...

编程日记 2025/5/10 2:51:06

Java技术复习提升 17反射

本章涉及到框架开发中必用的反射以及常用方法很重要注重理解并实践第17章反射 17.1 一个需求引出反射 package com.fsl; public class Cat {private String name "招财猫";public int age 10; //public的public Cat() {} //无参构造器public Cat(String name)…...

编程日记 2025/5/12 10:18:17

Python中的字符串

Python中的字符串在Python中，字符串是用于表示文本数据的基本数据类型。字符串可以包含字母、数字、符号和空格等字符。Python提供了多种方式来定义和操作字符串。字符串的定义在Python中，字符串可以用单引号或双引号 "" 括起来。例如…...

编程日记 2025/5/13 23:37:45

B站狂神说Mybatis+Spring+SpringMVC整合理解(ssm框架整合)

文章目录 0.写在前面(对mybatis,spring的理解)（不看可跳过）0.1 为什么需要mybatis0.2 为什么需要spring0.3为什么需要springmvc 1.新建ssmbuild数据库2.新建Maven项目3.初始化步骤3.1 配置下载maven依赖，构建资源导出3.2 连接数据库3.3建包&a…...

编程日记 2025/5/1 5:05:43

python:文件操作

一、文件路径在Windows系统中，每个磁盘都有自己的根目录，用分区名加反斜杠来表示。我们定位文件的位置有两种方法，一种是绝对路径，另一种是相对路径。绝对路径是从根目录出发的路径，路径中的每个路径之间用反斜杠来分…...

编程日记 2025/5/14 11:52:27

ECharts柱状图-极坐标系下的堆叠柱状图，附视频讲解与代码下载

引言： 在数据可视化的世界里，ECharts凭借其丰富的图表类型和强大的配置能力，成为了众多开发者的首选。今天，我将带大家一起实现一个柱状图图表，通过该图表我们可以直观地展示和分析数据。此外，我还将提供…...

编程日记 2025/5/14 11:16:42

HDMI协议

HDMI设计3--HDMI 1.4/2.0 Transmitter Subsystem IP - 皮皮祥 - 博客园 HDMI设计4--HDMI 1.4/2.0 Receiver Subsystem IP - 皮皮祥 - 博客园 HDMI协议 - 标签 - 皮皮祥 - 博客园...

编程日记 2025/3/4 20:20:29

SpringBoot集成Flowable

一、工作流介绍 1、概念通过计算机对业务流程的自动化管理。工作流是建立在业务流程的基础上，一个软件的系统核心根本上还是系统的业务流程，工作流只是协助进行业务流程管理。解决的是：在多个参与者之间按照某种预定义的规则自动进行传递文…...

编程日记 2025/5/12 11:23:39

五，[GXYCTF2019]Ping Ping Ping1

进入靶场，有提示我们在url试着输入本地IP，返回了ping命令既然要在url处传参，那就用postman，再输入ip127.0.0.1 & ls，试着列出目录内容 ok，好像是个脏话,它过滤了空格试着穿越又看到了脏话&#xff0…...

编程日记 2025/5/10 11:25:10

Linux -初识与基础指令1

博客主页：【夜泉_ly】本文专栏：【Linux】欢迎点赞👍收藏⭐关注❤️ 文章目录 📚 前言🖥️ 初识🔐 登录 root用户👥 两种用户➕ 添加用户🧑‍💻 登录普通用户⚙️ 常见…...

编程日记 2025/5/11 17:41:44

单片机学习笔记 12. 定时/计数器_定时

更多单片机学习笔记：单片机学习笔记 1. 点亮一个LED灯单片机学习笔记 2. LED灯闪烁单片机学习笔记 3. LED灯流水灯单片机学习笔记 4. 蜂鸣器滴~滴~滴~单片机学习笔记 5. 数码管静态显示单片机学习笔记 6. 数码管动态显示单片机学习笔记 7. 独立键盘单片机学习笔记 8…...

编程日记 2025/5/12 8:54:38

采用片上光学相控阵的激光雷达

激光雷达基础知识 LIDAR 基于众所周知的 RADAR 原理雷达是20世纪初就存在的著名技术激光雷达使用光频率而不是无线电波激光雷达和雷达使用相控阵的激光雷达通过干涉来提高方向性激光雷达的输出剖面是阵列因子和单天线远场的乘积。 N ：天线数量 k ：…...

编程日记 2025/5/12 13:22:34

LeetCode Hot100 11~20

目录子串11. 滑动窗口最大值12. 最小覆盖子串数组13. 最大子数组和14. 合并区间15. 翻转数组16. 除数字自身以外的乘积17. 缺失的第一个正数矩阵18. 矩阵置零19. 螺旋矩阵20 旋转图像90度子串 11. 滑动窗口最大值本题使用deque来维护一个单调队列注意删除元素和添加元素…...

编程日记 2025/5/13 3:11:51

泰州榉之乡全托机构探讨：自闭症孩子精细动作训练之法

当发现自闭症孩子精细动作落后时，家长们往往会感到担忧和困惑。那么，自闭症孩子精细动作落后该如何训练呢？今天，泰州榉之乡全托机构就来为大家详细解答。榉之乡大龄自闭症托养机构在江苏、广东、江西等地都有分校，一直…...

编程日记 2025/5/11 13:34:36

Mybatis：CRUD数据操作之修改数据update

Mybatis基础环境准备请看：Mybatis基础环境准备本篇讲解Mybati数据CRUD数据操作之修改数据用户在该页面书写需要修改的数据，点击提交按钮，就会将数据库中对应的数据进行修改。注意一点，如果哪儿个输入框没有输入内容&#xff…...

编程日记 2025/5/3 23:04:18

模拟器快速上手，助力HarmonyOS应用/服务高效开发

文章目录 1 创建模拟器1）打开设备管理界面2）设置本地模拟器实例存储路径3）创建一个模拟器（1）选择模拟器设备（2）创建模拟器（3）启动模拟器（4）关闭模…...

编程日记 2025/5/13 3:06:48

ERROR in [eslint] Invalid Options ‘extensions‘ has been removed.

看着这个报错感觉是版本不对引起的 ERROR in [eslint] Invalid Options: - Unknown options: extensions - extensions has been removed. ERROR in Error: Child compilation failed: [eslint] Invalid Options: - Unknown options: extensions - extensions has b…...

编程日记 2025/5/7 10:36:35

40分钟学 Go 语言高并发：GC原理与优化

GC原理与优化一、GC基础知识概览方面核心概念重要性优化目标GC算法三色标记法、并发GC⭐⭐⭐⭐⭐理解GC工作原理垃圾回收策略触发条件、回收步骤⭐⭐⭐⭐⭐掌握GC过程GC调优参数设置、性能监控⭐⭐⭐⭐优化GC效果内存管理内存分配、内存逃逸⭐⭐⭐⭐⭐减少内存压力让我们…...

编程日记 2025/5/13 17:32:37

【UG\NX二次开发-Block UI】指定方位 VisibleManipulatorHandles 设置控制器手柄可见

特定于块属性 VisibleManipulatorHandles 值 Origin 0x1 原点 Ratate X 0x10 旋转 Ratate Y 0x20 Ratate Z 0x40 Translate X 0x2 平移 Translate Y 0x4 Translate Z 0…...

编程日记 2025/5/13 11:06:45

一、介绍

二、 设置checkpoint检查点演示

1、 代码演示

2、测试代码效果

3、查看快照情况

三、在集群上运行

1、第一次运行

2、第二次运行

四、自定义检查点savePoint

1、提交一个flink job 打成jar包

2、输入一些数据，观察单词对应的数字的变化

3、执行savepoint操作，添加检查点

4、查看最近完成的flink job对应的savepoint

5、重新启动flink job，进行测试

6、观察变化

五、总结

相关文章：

二、设置checkpoint检查点演示

1、代码演示