### Checkpoint与Barrier Flink是一个有状态的流处理框架，因此需要对状态做持久化，Flink定期保存状态数据到存储空间上，故障发生后从之前的备份中恢复，这个过程被称为Checkpoint机制。而Checkpoint为Flink提供了Exactly-Once的投递保障。 流处理
### 概述 Flink Streaming API借鉴了谷歌数据流模型(Google Data Flow Model)，它的流API支持不同的时间概念。Flink明确支持以下3个不同的时间概念。 Flink明确支持以下3个不同的时间概念。 (1)事件时间：事件发生的时间，由产生（或存储）事件的设备
CDC是(Change Data Capture变更数据获取)的简称。 核心思想是，监测并捕获数据库的变动（包括数据 或 数据表的插入INSERT、更新UPDATE、删除DELETE等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 ## Flink CDC的设
# 项目Springcloud，认证中心方式实现SSO使用开源框架Sa-Token >本身的单独访问每个客户端服务的单点就没有问题。然后单点通过Fegin调用就不好使了！ ##### 主要使用的Sa-Token的微服务单点功能 ##### 使用的依赖如下 ```xml cn.dev33 sa-tok
# 令牌桶算法 > 系统会维护一个令牌（token）桶，以一个恒定的速度往桶里放入令牌（token），这时如果有请求进来想要被处理，则需要先从桶里获取一个令牌（token），当桶里没有令牌（token）可取时，则该请求将被拒绝服务。令牌桶算法通过控制桶的容量、发放令牌的速率，来达到对请求的限制。 >
1.简介 我们在日常工作中，会经常遇到弹出警告框的问题，弹框无法绕过，必须处理才可以执行后续的测试，所以弹框处理也是我们必须掌握的一个知识。宏哥在java+selenium系列文章中介绍过这部分内容。那么，playwright对于弹框的处理是怎样的？是否比selenium更加简单呢？下面我们就来介绍
一般运行java应用都会根据实际情况设置一些jvm相关运行参数 特别是有关内存和oom溢出等参数，方便后续问题定位和解决 如常用的以下配置 nohup java -Xms256m -Xmx24g -Xmn8g -verbose:gc -XX:+PrintGCDateStamps -XX:+Print
SqlServer安装时企业版会有两种选项：Microsoft SQL Server Enterprise (64-bit)，Microsoft SQL Server Enterprise: Core-based Licensing (64-bit)。前者为Enterprise Server+CAL
场景 一般情况下，我们会对现有系统进行压测等方式，来了解系统最大的吞吐量等等，通过这种方式得知系统在生产环境下可扛住的压力，如果我们想了解在压测的链路过程中，是哪些地方执行时间过长，影响了系统的吞吐量，可以使用火焰图的方式来观察。 工具 生成火焰图需要两个工具： 1. async-profiler：
https://www.modb.pro/db/570143?utm_source=index_ori 内容概述 Oracle数据库中切换redo日志会触发检查点事件，那么在PostgreSQL中是否也会触发checkpoint事件呢？ Oracle中测试 [oracle@orcldb ~]$ sq
前言 Ubuntu每次升级都会修改一部分组件. 从1804开始Ubuntu开始使用netplan的方式进行网络设置. 但是不同版本的配置一直在升级与变化. 今天掉进坑里折腾了好久. 所以这边总结一下, 以便备忘. 番外 WorkStation虚拟机迁移ESXi 公司机器配置太lowB,跑虚拟机就像是
保存到redis中的key 前半段会出现乱码问题 原来配置： @Configuration@EnableCachingpublic class RedisCacheConfig { @Bean public CacheManager cacheManager(RedisTemplate
https://zhuanlan.zhihu.com/p/504348343 在公司的网络或者是客户的网络环境中，经常会有只能使用局域网而不能使用访问互联网的情况，其目的也很显然，为了更好的保护数据安全。 但在这种情况下，对于运维而言，如果突然要安装一款软件的话，就会变得很困难，因为它往往有很多依赖
https://my.oschina.net/lenve/blog/5952439 我们应该都知道 socket（套接字），你可以认为我们的通信都要基于这个玩意，而常说的网络通信又分为 TCP 与 UDP 两种，下面我会以 TCP 通信为例来阐述下 socket 的通信流程。 不过在此之前，我先来说
当我们远距离传输时，通常会使用光纤来传输。因为光纤的传输距离很远，一般来说单模光纤的传输距离在10千米以上，而多模光纤的传输距离最高也能达到2千米。而在光纤网络中，我们常常会使用到光纤收发器。那么光纤收发器怎么连?我们一起来了解下。 一、光纤收发器的作用 ①光纤收发器可以延长以太网传输距离，扩展以太
在Linux环境下C程序经常会出现A segmentation fault（段错误），如果我们的程序只有几十行，那么我们可以通过printf输出调试来找到哪个地方出现了异常，但如果是在项目中，如果我们还是通过print找查找错误，那么效率会很低。那么我们来学习一下Linux环境下通过core文件来找
我感觉 这样理解也有点不对 timestamp 应该是不带时区 只是 UTC1970-1-1 的时间戳 但是展示时会根据时区做一下计算 date time 就不会做转换而已. 原创：打码日记（微信公众号ID：codelogs），欢迎分享，转载请保留出处。 简介# 众所周知，mysql中有两个时间类型
在Linux系统中经常会使用dd命令来测试硬盘的写入速度，命令会涉及几个常用参数：sync、dsync、fsync与fdatasync # dd if=/dev/zero of=/tmp/1G bs=4k count=256000 oflag=dsync # dd if=/dev/zero of=/
我们在操作数据库的时候，可能会由于并发问题而引起的数据的不一致性（数据冲突），如何保证数据并发访问的一致性、有效性，是所有数据库必须解决的一个问题，锁的冲突也是影响数据库并发访问性能的一个重要因素，从这一角度来说，锁对于数据库而言就显得尤为重要。 今天就分享下MySQL相关的最全锁，希望你学习后能更
Shell补遗 背景 公司一台机器总是会在没有更新补丁的情况下启动失败. 查看所有的配置都没有问题. 但是就是不启动 没办法,准备写一个检查进行启动. 最近写shell很少. 所以总结一下. 思路 判断有没有 服务进程. 如果没有服务进程. 调用启动服务进程 如果有服务进程, 那就不做任何操作. 所
