Flink中异步AsyncIO的实现 (源码分析)
先上张图整体了解Flink中的异步io 阿里贡献给flink的，优点就不说了嘛，官网上都有，就是写库不会柱塞性能更好 然后来看一下， Flink 中异步io主要分为两种 一种是有序Ordered 一种是无序UNordered 主要区别是往下游output的顺序（注意这里顺序 ...
原文：Flink 中LatencyMarks延迟监控（源码分析）
流式计算中处理延迟是一个非常重要的监控metric flink中通过开启配置 metrics.latency.interval 来开启latency后就可以在metric中看到askManagerJobMetricGroup operator id operator subtask index latency指标了 如果每一条数据都打上时间监控 输出时间 输入时间，会大量的消耗性能 来看一下fli ...
2019-12-13 17:19 0 710 推荐指数：
相关推荐
flink checkpoint 源码分析 （一）
转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/8029356.html checkpoint是Flink Fault Tolerance机制的重要构成部分，flink checkpoint的核心类名为 ...
flink checkpoint 源码分析 （二）
转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/8260370.html flink checkpoint 源码分析 （一）一文主要讲述了在JobManager端定时生成TriggerCheckpoint的代码部分，本文继续研究 ...
Flink中Periodic水印和Punctuated水印实现原理(源码分析)
） AssignerWithPeriodicWatermarks（周期性的生成水印） 来看一下源码中 ...
Flink中Idle停滞流机制(源码分析)
前几天在社区群上，有人问了一个问题 既然上游最小水印会决定窗口触发，那如果我上游其中一条流突然没有了数据，我的窗口还会继续触发吗？ 看到这个问题，我蒙了？？？？ 对哈，因为我是选择上游所有流中水印最小的一条作为当前水印时间，那万一最小水印的那条流突然里面没有数据了 那我的最小水印不就 ...
Flink中watermark为什么选择最小一条(源码分析)
昨天在社区群看到有人问，为什么水印取最小的一条？这里分享一下自己的理解 首先水印一般是设置为：(事件时间 - 指定的值) 这里的作用是解决迟到数据的问题，从源码来看一下它如何解决的 先来看下windowOperator.java接收到数据以后做了什么 在processElement方法中 ...
Flink中TaskManager端执行用户逻辑过程(源码分析)
TaskManager接收到来自JobManager的jobGraph转换得到的TDD对象，启动了任务，在StreamInputProcessor类的processInput()方法中 通过一个while(true)中不停的拉取上游的数据，然后调用 ...
Flink中的CEP复杂事件处理 (源码分析)
中包含状态（Flink中State对象），以及连接状态的边（Flink中StateTransition ...