老周聊架构
0获赞0粉丝0关注
基于内网高可用 VIP 实现生产、容灾环境切换
开篇之前,老周觉得有必要先铺垫一下,我们先来说一说 VIP ( Virtual IP ) 相关的技术。一、虚拟IP概述1.1 VIP 是什么虚拟IP(Virtual IP Address,简称VIP)是一个未分配给真实弹性云服务器网卡的IP地址。弹性云服务器除了拥有私有IP地址外,还可以拥有虚拟IP
老周聊架构
1
聊聊Flink:Flink的容错机制
一、前言我们上一篇讲了 Flink的状态管理 ,这一篇我们来说一说Flink的容错机制。在分布式计算系统中,为了保证数据的一致性需要对数据进行一致性快照。Flink和Spark在做流式计算时,为了保证数据一致性都借鉴了Chandy-Lamport算法原理,Chandy-Lamport算法目标是让多个
老周聊架构
0
聊聊Flink:这次把Flink的触发器(Trigger)、移除器(Evictor)讲透
一、触发器(Trigger)Trigger 决定了一个窗口(由 window assigner 定义)何时可以被 window function 处理。每个 WindowAssigner 都有一个默认的 Trigger。如果默认 trigger 无法满足你的需要,你可以在 trigger(…)...
老周聊架构
0
聊聊Flink:这次把Flink的的window分类(滚动、滑动、会话、全局)...
一、窗口窗口(Window)是处理无界流的关键所在。窗口将流分成有限大小的“桶”,我们可以在其上应用算子计算。Flink可以使用window()和windowAll()定义一个窗口,二者都需要传入一个窗口分配器WindowAssigner,Window...
老周聊架构
0
聊聊Flink:Flink的分区机制
一、前言flink任务在执行过程中,一个流(stream)包含一个或多个分区(Stream partition)。TaskManager中的一个slot的subtask就是一个stream partition(流分区),一个Job的流(stream)分布在多个不同的Slot上执...
老周聊架构
0
聊聊Flink:Flink的基础架构
一、前言 哈喽,大家好,我是微信公众号【老周聊架构】的作者老周,老周这次给大家分享下Flink系列的知识。作为Flink系列的开篇之作,我脑海中想着有没有一种很好的方式来让大家通俗易懂的了解Flink。因为你一上来就...
老周聊架构
0