IP属地：上海
-
Flink⼤状态作业调优实践指南：Flink SQL 作业篇摘要：本文整理自俞航翔、陈婧敏、黄鹏程老师所撰写的大状态作业调优实践指南。由于内容丰富，本文中篇内容分享 Flink SQL 作业大状态导致反压的调优原理与方法，主要分为以下...
-
关于使用Flink RocksDB状态后端时一定要写MapState而非ValueState<Map>这档事（以及解决方法）前言 抱歉起这种烂大街的日本轻小说风格标题来吸引注意力。原本我认为这是常识，不需要专门写一篇文章来讲解如此细碎的点。但是在最近工作巡检中发现了越来越多如同ValueState...
-
从一例状态引发的性能问题谈Flink状态序列化前言 好久不见（鞠躬 最近处在转型期，每天忙到飞起，关注具体技术细节的精力自然就比较少了（上一篇许下的周更承诺也食言了 = =）。上周帮助他人快速解决了一个因误用Flink状...
-
Flink 源码之AsyncFunction
Flink源码分析系列文档目录 请点击：Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 简介 Flink的特...
-
Flink 使用之 SQL UDF
Flink 使用介绍相关文档目录 Flink 使用介绍相关文档目录[https://www.jianshu.com/p/74f1990d047c] 简介 在使用纯Flink ...
-
Flink 源码之 LookupTableSource
Flink源码分析系列文档目录 请点击：Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 简介 Flink一个...
-
【Flink SQL】如何利用 Calcite 扩展 Flink Function 语法
1.Calcite 如何实现 sql 语法的解析 Calcite 使用 javacc 作为语法解析器[https://zhuanlan.zhihu.com/p/5096817...
-
【Flink SQL】如何解析和校验 Flink SQL
1.flink sql 解析 方法1：直接创建 flink sql parser 解析多行 sql 方法2：通过 table env 获取的 flink sql parser...
-
新一代缓存Caffeine，速度确实比Guava的Cache快
来自公众号：小姐姐味道作者：小姐姐养的狗作者简介：小姐姐味道 (xjjdog)，一个不允许程序员走弯路的公众号。聚焦基础架构和Linux。十年架构，日百亿流量，与你探讨高并...
-
深入分析Flink的operator chain（算子链）机制前言 这篇是昨晚没写完的，今晚补全发出来。 Flink算子链简介 “为什么我的Flink作业Web UI中只显示出了一个框，并且Records Sent和Records Re...
-
-
Flink 快照分析：定位大状态和数据倾斜的算子
在 Flink 作业中，无论是 SQL 还是 JAR 模式，常常会直接或者间接地使用到状态（State）。当 Flink 进行快照时，用户定义的这些状态数据可以被保存在状态点...
-
Flink新特性之网络缓存消胀（Network Buffer Debloating）机制前言 最近正在准备关于Flink 1.13 / 1.14版本新特性的内部分享，顺便做点记录。 又见网络缓存 很久没有聊过Flink的网络栈了，但相信大家对网络缓存（Netwo...
-
Flink流量控制与反压机制完全总结前言 笔者最近回顾自己对Flink技术栈细节的理解，发现对Flink的网络栈、流控与反压这一套机制存在比较大的盲区。虽然平时多次处理过作业反压的问题，但是不完全理解背后的实现...
-
手写理解Callable,Future,Executor
前言 Callable,Future,Executor都是java.util.concurrent包下的工具类，作者李二狗，为了彻底吃透它们的概念，今天就假设这些类都不存在，...
-
G1垃圾收集器实现原理1 与垃圾收集器有关的算法 在分析G1前先简单回顾一下与垃圾收集器相关的算法。通常所谓的垃圾收集器更多地是指跟踪垃圾收集器（Tracing Garbage Collectio...
-
知识回顾｜并发｜ThreadLocal、ThreadPoolExecutor本文回答以下问题，文内可能有遗漏、错误或表达不够清晰的地方。 ThreadLocal① 了解ThreadLocal使用场景和内部实现② 使用ThreadLocal时要注意什么...
-
Flink 使用之批模式和流模式
Flink 使用介绍相关文档目录 Flink 使用介绍相关文档目录[https://www.jianshu.com/p/74f1990d047c] 批模式和流模式 Flink...
