发简信
IP属地：上海
-
Flink timer注册与watermark触发[转载自网易云音乐实时计算平台经典实践知乎专栏]经作者magina本人同意，转载自原文在flink中无论是windowOperator还是KeyedProcessOperator都持有Inte...
-
Flink任务物理内存溢出问题定位问题现象 一个使用10秒滚动窗口的任务在平稳运行一段时间之后出现了频繁的重启。在TaskManager日志中能看到以下文本： 原因定位 首先可以...
-
Apache Flink源码解析 （八）Flink的HighAvailabilityServices概述 Flink内部有一些服务是JobMaster和TaskExecutor共用的。如HighAvailabilityServices, Rpc...
-
有状态的流处理系统的弹性伸缩(Elastic Scaling)前言 看到一篇14年的关于流处理系统的弹性缩扩容的论文Elastic Scaling for Data Stream Processing，觉得...
-
Apache Flink源码解析 （七）Flink RPC的底层实现
Prerequisites Flink的RPC服务是基于Akka Remote实现的。一个简单的Akka Remoting ActorSyste...
-
关于流数据上的事务操作
概述 最近Flink母公司Data Artisans发布了一篇博客关于一个新的组件Streaming Ledger，给出了流数据的事务解决方案（...
-
Apache Flink源码解析 （六）执行计划生成之StreamGraph-上半篇: 通过DataStream API概述 根据上一篇文章 DataStream API 可以得知每一个方法生成的Transformation和实际运行中对Task的影响。事实上从T...
-
Apache Flink源码解析 （五）DataStream API概述 这篇文章是但不仅仅是官方文档的中文翻译，还有里面每一个方法对应的Transformation和运行时对Task的影响。 Prerequis...
-
Leetcode算法解析101+
<center>#104 Maximum Depth of Binary Tree</center> link Description:Give...
个人介绍
Apache Flink Contributor，巴西铁杆，巴萨死忠，硬摇粉，分布式系统爱好者，github: https://github.com/Clarkkkkk