13篇文章 · 20775字 · 2人关注
-
【Flink 精选】TaskManager 详解 — 架构本文重点介绍 TaskManager 总体架构。TaskManager 整体是一个 RPC 服务端，提供的接口，例如请求 slot、提交任务、取...
-
【Flink 精选】Flink-1.10 内存调优实践1.JobManager 内存调优 1.1 JobManager 内存模型的介绍 JobManager 是 Java 进程，从 JVM 角度来看...
-
【Flink 精选】Kafka Consumer 源码详解本文首先进行 Flink Kafka Consumer 原理分析，结合 SourceFunction 和 Kafka Client API 详解...
-
【Flink 精选】Watermark 常见问题及其定位思路本文介绍了 Watermark 的应用场景，分析了常见的 Watermark 问题及其定位手段。 1 Watermark 应用场景 背景：在现实...
-
【Flink 精选】阐述 Watermark 机制，剖析 Watermark 的产生和传递流程本文阐述 Flink 的事件时间和 Watermark 机制，剖析 Watermark 产生和传递的流程。 1 Event time 和 Wat...
-
【Flink 精选】Checkpoint 机制如何保证 Exactly-Once 语义问题1：阐述 Flink 提供的三种数据处理语义，解释 Checkpoint 机制如何保证 Flink 程序结果的 Exactly-Once 语...
-
【Flink 精选】阐述 Flink 的容错机制，剖析 Checkpoint 实现流程阐述 Flink 提供的容错机制，解释分布式快照 Chandy Lamport 算法逻辑，剖析 Flink Checkpoint 具体实现流...
-
【Flink 精选】如何优化大状态作业？本文从监控、参数调整、资源规划等方面，优化 Flink 大状态作业的常见问题。 背景：Flink 有状态作业能可靠地运行，必须满足以下两个条件 ...
-
【Flink 精选】如何排查 Checkpoint 异常问题？本文详解 Checkpoint 机制，分享 Checkpoint 问题排查的手段，包括失败、延期等问题。 1.Checkpoint 机制 1.1...
