前言 Flink的检查点和恢复机制定期的会保存应用程序状态的一致性检查点。在故障的情况下，应用程序的状态将会从最近一次完成的检查点恢复，并继续处...
投稿
收录了14篇文章 · 2人关注
-
Flink 端对端一致性 -
【Flink 精选】如何排查 Checkpoint 异常问题？本文详解 Checkpoint 机制，分享 Checkpoint 问题排查的手段，包括失败、延期等问题。 1.Checkpoint 机制 1.1...
-
Flink新特性之非对齐检查点（unaligned checkpoint）简介前言 在食用本文之前，建议看官先充分食用这两篇文章：《Chandy-Lamport分布式快照算法小记》与《深入理解Flink的轻量级异步屏障快照...
-
Apache Flink 进阶（三）：Checkpoint 原理解析与应用实践简介： 大家好，今天我将跟大家分享一下 Flink 里面的 Checkpoint，共分为四个部分。 首先讲一下 Checkpoint 与 sta...
-
Flink 迟到元素的处理
前言 前面文章Flink中的时间语义 和WaterMark有详细介绍过Flink WaterMark。WaterMark的出现是用来解决乱序时间...
-
Flink kafka connector
1.kafka connector版本选取 Flink有多个Kafka connector：universal，0.10和0.11。 Flink...
-
10.flink-1.11.1 安装部署1 Standalone模式 1.0 集群规划 node06node07node08node10TaskManagerTaskManagerT...
-
Flink 架构1.Flink 运行时的角色 Flink系统架构中包含了两个角色，分别是JobManager和TaskManager，是一个典型的Master-...
-
Flink中的时间语义 和WaterMark1. Flink 时间语义 Flink定义了三类时间 处理时间（Process Time）数据进入Flink被处理的系统时间（Operator处...
-
Flink API1.Flink API介绍 Flink提供了不同的抽象级别以开发流式或者批处理应用程序 Stateful Stream Processing 最...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1897916/Snipaste_2020-07-08_14-13-21.png', '推荐专题《flink》（ 分享自 @简书 ）','https://jianshuapi.com/c/dff2e0148a5f?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','页面编码gb2312|utf-8默认gb2312'));){kind=link}