前面我们尝试用flink写了一个WordCount程序，并且介绍了flink提供的api层级，接下来我们正式来学习flink的DataStream API。为什么先学习DataStream API，而不是ProcessFunction API，这是因为ProcessFunction API是通过DataStream API调用的，它作为DataStream API的补充，可以实现DataStrea

我们来看一下flink官网的图：光看图就头晕了，我们可以来整理一下。首先flink job任务状态总共有：CreatedRunningFinishedFailedCanceledFailingCancelingRestartingSuspended根据个人理解，我们可以把这些状态分为四大类：起始态中间态最终态过渡态起始态表示任务启动时的状态，中间态表示任务运行时的状态，最终态表示任务最后的状态，过

vscode编辑器有一个插件Remote VSCode，可以帮助我们在本地机器上使用vscode直接编辑远程文件。安装及配置步骤本地配置1、打开vscode，安装插件Remote VSCode，按下快捷键Shift+Command+R，搜索remote，启动命令Remote: Start Server，2、打开命令行，输入命令ssh -R 52698:127.0.0.1:52698 远...

在hadoop中，在map方法结束写出数据的时候需要对数据进行分区，具体分区实现由Partitioner类提供，而Partitioner类的加载逻辑如下：partitions = jobContext.getNumReduceTasks();if (partitions > 1) {// 设置的分区数（即reduce task的个数）大于1，则使用设置的分区类partitioner = (o

翻译自：https://www.geeksforgeeks.org/java-virtual-machine-jvm-stack-area/在线程创建的时候，JVM会为每个线程创建一个单独的栈空间。JVM的栈内存不需要是连续的。JVM在栈上会进行两个操作：压入和弹出栈帧。对于一个特定的线程来说，栈被称为运行时栈（Run - Time Stack）。这个线程调用的每个方法会被存储在响应的运行时...

在前文我们写了一个WordCount程序体验了一下flink程序的编写。在本篇中我们详细学习下flink api的分类及其应用场景。Flink’s APIflink提供了4个层次的api抽象：在最下层，就是有状态流式编程，它提供了状态编程和时间编程（时间编程后面会学到）的基础能力。它通过Process Function嵌入到DataStream API中。它It is embedded into