铛铛铛clark

铛铛铛clark

IP属地：上海

Flink timer注册与watermark触发[转载自网易云音乐实时计算平台经典实践知乎专栏]
经作者magina本人同意，转载自原文在flink中无论是windowOperator还是KeyedProcessOperator都持有Inte...

0.2 1960 0 2
Flink任务物理内存溢出问题定位
问题现象一个使用10秒滚动窗口的任务在平稳运行一段时间之后出现了频繁的重启。在TaskManager日志中能看到以下文本：原因定位首先可以...

0.9 14886 3 8

Apache Flink源码解析（八）Flink的HighAvailabilityServices
概述 Flink内部有一些服务是JobMaster和TaskExecutor共用的。如HighAvailabilityServices, Rpc...

0.1 2774 0 3
有状态的流处理系统的弹性伸缩(Elastic Scaling)
前言看到一篇14年的关于流处理系统的弹性缩扩容的论文Elastic Scaling for Data Stream Processing，觉得...

0.9 1576 1 8
Apache Flink源码解析（七）Flink RPC的底层实现
Prerequisites Flink的RPC服务是基于Akka Remote实现的。一个简单的Akka Remoting ActorSyste...

1.3 5632 1 16
关于流数据上的事务操作
概述最近Flink母公司Data Artisans发布了一篇博客关于一个新的组件Streaming Ledger，给出了流数据的事务解决方案（...

0.1 1196 2 3
Apache Flink源码解析（六）执行计划生成之StreamGraph-上半篇: 通过DataStream API
概述根据上一篇文章 DataStream API 可以得知每一个方法生成的Transformation和实际运行中对Task的影响。事实上从T...

0.4 2809 0 11 1

Apache Flink源码解析（五）DataStream API
概述这篇文章是但不仅仅是官方文档的中文翻译，还有里面每一个方法对应的Transformation和运行时对Task的影响。 Prerequis...

0.2 9991 0 12 1
Leetcode算法解析101+
<center>#104 Maximum Depth of Binary Tree</center> link Description:Give...

1568 0 0