Flink实现Kafka到Mysql的Exactly-Once 背景 最近项目中使用Flink消费kafka消息，并将消费的消息存储到mysql...

Blink First Time & Flink-sql 背景 blink开源，目前在https://github.com/apache/fli...

看了 BucketSink 的相关源码。着重看了它的checkpoint以及故障恢复机制。把大概的理解梳理如下：BucketSink 大体的工作...

LocalFlinkMiniCluster 集群的actor 模型 相关的主要类图如下： AkkaRpcActor持有一个rpcEndpoint...

Flink系统组成 Flink是一个分层系统，从下到上分为：系统部署层、任务运行层、API层以及基于API开发的通用库层(Libraries)。...

一.Time 1.DataStream支持3种Time env.setStreamTimeCharacteristic(TimeCharacte...

1.什么是异步IO ，当请求外部系统或者耗时操作，需要异步IO 2.AsyncDataStream 3.实现原理 有序 processing t...

一.Flink Runtime 1.运行时架构 Client JobManager（master节点） TaskManager（Salve节点）...

1.git 下载源码 git clonehttps://github.com/apache/flink.git 公司目前使用的是1.5.0版本，...

checkPoint简介 为了保证state的容错性，Flink需要对state进行checkpoint。 Checkpoint是Flink实现...