Checkpoint在分布式流处理框架的准确性具有重要意义。Flink实现了基于Chandy-Lamport算法的checkpoint机制。在消息可靠性保障，集群升级等场景具...
发简信
IP属地：黑龙江
-
Flink checkpoint流程源码分析
-
死磕了《禅与摩托车修理艺术》
《禅与摩托车维修艺术》，看书名还以为是一个摩托车维修工在维修工作中禅性的领悟，在拿到这本书后我还逗趣的发了一条朋友圈，说：三月的第一本书，竟是蓝翔的教科书。 主人公带着儿...
-
ELK安装和使用如果安装ELK只是为了玩玩，可以单机搭建没问题，但是真实业务运行时，必须考虑实用和效率问题。ES client节点： 作为ES节点的任务协调节点，所有来自kibana的请求，...
-
java正则表达式笔记
正则表达式是一种强大的字符串处理工具,平时经常会用到。这里完整的做一次总结，以便查阅记忆。 1. 字符串中的正则表达式 使用正则表达式可以对字符串进行查找、提取、分割、替换等...
-
发布-订阅者模式和事件监听器模式订阅者模式 订阅者和发布者模式，通常用于消息队列中。一般有两种形式来实现消息队列，一是使用生产者和消费者来实现，二是使用订阅-发布者来实现。其中使用订阅者和发布者实现消息队列...
-
性能分析系列-小命令保证大性能最近在工作中经常和性能压测工作打交道，积累了一些性能分析经验，我觉得这些经验对每一个开发者都有帮助的，能开发出性能高的代码也是我们的最终目标。 由易到难，我们逐步介绍不同命令...
-
14：Spark Streaming源码解读之State管理之updateStateByKey和mapWithState解密
首先简单解释一下什么是state(状态)管理？我们以wordcount为例。每个batchInterval会计算当前batch的单词计数，那如果需要计算从流开始到目前为止的单...
