本博客所有内容均适用知识共享-署名-相同方式共享（CC-BY-SA）4.0协议。
发简信
IP属地：河南
-
-
-
李开复：从患癌症到肿瘤消失，在抗癌中我更加确信睡眠比什么都重要
就像大部分的病友一样，在发现自己罹癌之后，我急切地想了解癌症是怎么发生的，身体到底需要什么，如何保持身体健康…… 一路上我看了很多书籍，也接触了不少名医，接受了不少朋友的建议...
-
Flink Checkpoint变迁与实践一、历史变迁 在Flink 1.0.0时期 提供了RocksDB的支持，这个版本之前所有的状态都只能存在进程的内存里面，这个内存总有存不下的一天，如果存不下则会发生OOM。如...
-
初识Flink WaterMarker
前言 对于流计算来说，最核心的概念就是无穷数据集，而用来处理无穷数据集的计算就可以称为流计算。面对无穷数据集，有多种多样的处理方式，但是大致上可以分为四类：1、时间无关：最基...
-
Jobs and SchedulingScheduling 1、Flink的Execution resources是通过Task Slots定义的。每个TaskManager 都有一个或多个Task Slots，...
-
MemorySegment
概述 就像我们所知道的，Flink采用了自己管理内存的方式，或者说积极的内存管理，而MemorySegment就是Flink实现自己内存管理的核心。 那么MemorySegm...
-
Data exchange between tasks基本原则 https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+between+tasks 1、Fl...
-
Rescaling Stateful Applications in Production一、概述 数据局部性是Flink中的一个关键原则，并且强烈影响状态的存储和访问方式。Flink中的状态都是Local State。Why local state is a f...
-
Actor system(Akka) in Flink一、概述 Flink's distributed execution consists of two important processes, master and work...
-
Physical Partitioning in Flink Streaming一、Physical partitioning 在一个transformation之后，Flink也提供了底层API以允许用户在必要时精确控制流分区。 所谓的Physical...
-
Impala schema基本设计原则
在进行任何概念验证工作，移植练习或部署到生产之前，请将这些指南用作check list。 1、Prefer binary file formats over text-bas...
-
JStorm：Window机制
0x01、前言 1、Storm作为经典流计算框架，由于不支持Window，更别说Event Time了，虽说Trident支持了exactly-once语义，但是性能会急剧下...
-
Flink中的计算资源
一、Flink Graph（DAG） 在Flink中的执行图可以分成四层：StreamGraph -> JobGraph -> ExecutionGraph -> 物理执行图...
