Flink 源码解析 —— 深度解析 Flink 是如何管理好内存的？
前言 如今，许多用于分析大型数据集的开源系统都是用 Java 或者是基于 JVM 的编程语言实现的。最着名的例子是 Apache Hadoop，还有较新的框架，如 Apache Spark、Apache Drill、Apache Flink。基于 JVM 的数据分析引擎面临的一个常见挑战 ...
原文：Flink 源码解析 —— 深度解析 Flink 序列化机制
Flink 序列化机制 https: t.zsxq.com JaQfeMf 博客 Flink 从 到 学习 Apache Flink 介绍 Flink 从 到 学习 Mac 上搭建 Flink . . 环境并构建运行简单程序入门 Flink 从 到 学习 Flink 配置文件详解 Flink 从 到 学习 Data Source 介绍 Flink 从 到 学习 如何自定义 Data Source ...
2019-08-13 21:48 0 379 推荐指数：
相关推荐
[源码解析] 从TimeoutException看Flink的心跳机制
[源码解析] 从TimeoutException看Flink的心跳机制 目录 [源码解析] 从TimeoutException看Flink的心跳机制 0x00 摘要 0x01 缘由 0x02 背景概念 2.1 四大 ...
Flink的类型与序列化
1.序言 Flink在内部以二进制的格式将数据保存，由于普通的Java对象类型和内部二进制格式不一致，需要一套相互转换机制来进行序列化和反序列化。 2.DataStream类型系统 2.1 物理类型 Flink支持的物理类型如下图所示： 分为基础类型、数组类型、复合类型、辅助类型 ...
[白话解析] Flink的Watermark机制
[白话解析] Flink的Watermark机制 0x00 摘要 对于Flink来说，Watermark是个很难绕过去的概念。本文将从整体的思路上来说，运用感性直觉的思考来帮大家梳理Watermark概念。 0x01 问题 关于Watermark，很容易产生几个问题 Flink 流 ...
flink on yarn部分源码解析
转发请注明原创地址：https://www.cnblogs.com/dongxiao-yang/p/9403427.html flink任务的deploy形式有很多种选择，常见的有standalone，on yarn , Meos , Kubernetes等方式，目前公司内部统一采用 ...
Flink源码解析(三)——从RM与TM的心跳交互分析Flink心跳机制
0. 说明 基于Flink 1.12 1. 背景知识 1.1 Actor模型 Flink底层RPC是通过AKKA实现的，AKKA是基于Actor模型实现的框架。下面，将大致介绍一下actor模型。 在Actor模型中，一切事物都是actor，一个actor是一个基本的计算单元，每个 ...
【源码】Flink sql 流式去重源码解析
本文基于 flink 1.12.0 之前尝试了一下 flink sql 的 去重和Top n 功能，只是简单的看了下官网，然后用 sql 实现了功能，但是还有些疑问没有解决。比如：不使用 mini-batch 模式，去重的结果很单一，降序就只输出第一条数据（升序就一直输出最后一条） 为了解 ...
《Flink 源码解析》—— 源码编译运行
更新一篇知识星球里面的源码分析文章，去年写的，周末自己录了个视频，大家看下效果好吗？如果好的话，后面补录发在知识星球里面的其他源码解析文章。 前言 之前自己本地 clone 了 Flink 的源码，编译过，然后 share 到了 GitHub 上去了，自己也写了一些源码的中文注释 ...