前一篇文章 一文搞懂 Flink window 元素的顺序问题 我们已经知道了，state 的获取、更新、清除等都与 key 相关。那么 key 是如何设置的呢？

1. 起因在我们使用 evictor 算子的时候，官网有这样的一句话： Flink provides no guarantees about the order of the elements within a window. This implies that although an evictor may ......

Flink作为新一代的大数据项目，除了尽量匹配其他大数据项目所提供的能力之外，还拥有一些不错的特性，列举如下：

前面两篇我已经讲过 Flink getRuntimeContext().getMapState的时候发生了什么？以及 Flink StateDescriptor Name的作用。 今天我们在这个的基础上一起来看一下，为什么 key state 仅仅与 key 有关，无论我取数据还是修改...

​在《什么的是用户画像》一文中，我们已经知道用户画像对于企业的巨大意义，当然也有着非常大实时难度。那么在用户画像的系统架构中都有哪些难度和重点要考虑的问题呢？...

本文是《Flink处理函数实战》系列的第二篇，上一篇《Flink处理函数实战之一：ProcessFunction类》学习了最简单的ProcessFunction类，今天要了解的KeyedProcessFunction，以及该类带来的一些特性；...

如下图，在常规的业务开发中，SQL、Table API、DataStream API比较常用，处于Low-level的Porcession相对用得较少，从本章开始，我们一起通过实战来熟悉处理函数(Process Function)，看看这一系列的低级算子可以带给我们哪些能力？...

学习Flink的ProcessFunction过程中，官方文档中涉及状态处理的时候，不止一次提到只适用于keyed stream的元素，如下图红框所示：

Flink Kubernetes与Flink Native Kubernetes是不同的概览，先回顾一下Flink Kubernetes：

在学习和开发flink的过程中，经常需要准备数据集用来验证我们的程序，阿里云天池公开数据集中有一份淘宝用户行为数据集，稍作处理后即可用于flink学习；...