前言 1 Flink基础（适合初入职场） 简单介绍一下 Flink Flink相比传统的Spark Streaming区别? Flink的组件栈有哪些？ Flink 的运行必...
发简信
IP属地：北京
-
那些被问懵的Flink面试题 -
一文搞懂 Flink 网络流控与反压机制看完本文，你能get到以下知识Flink 流处理为什么需要网络流控？Flink V1.5 版之前网络流控介绍Flink V1.5 版之前的反压策略存在的问题Credit的反压...
-
记录Flink1.9线上checkpoint失败的问题最新在线上更新了代码之后导致了任务在消费kafka数据的时候,突然就不消费数据了,发现原因在公司的可视化界面中,看不到数据的更新,进入flink监控页面中看到任务没有fail...
-
Flink Sql on Hive 的生产遇到的坑以及优化（持续更新 ...）
1、HiveSource-xxxx.xxxx's parallelism (200) is higher than the max parallelism (128). Pl...
-
深入理解Flink的轻量级异步屏障快照（ABS）算法Prologue 在很久之前，笔者曾简单介绍了Chandy-Lamport分布式快照算法，如果看官还未读过，建议作为前置知识补充一下。 用过Flink的人都会知道检查点机制有...
-
Flink intervalJoin 使用和原理分析1.前言 Flink中基于DataStream的join，只能实现在同一个窗口的两个数据流进行join，但是在实际中常常会存在数据乱序或者延时的情况，导致两个流的数据进度不一...
-
Flink 源码之Credit Based反压
Flink源码分析系列文档目录 请点击：Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 什么是credit反...
