学习 Flink(九):Async I/O

见文生意,Async I/O 是用于异步读写外部数据源的算子。 流表关联数据库维度表,可以使用 Async I/O 去实现。下图为同步 I/O 和异步 I/O 的对比: 举🌰 定义异步函数: public abstract class JDBCAsyncFunction<IN, »

学习 Flink(七):Flink on YARN

更新至 Flink 1.8.2 版本 Flink 支持多种集群部署: Standalone Flink on YARN Flink on Mesos Flink on Kubernetes Flink on YARN 支持两种模式: 会话模式(Session Mode),在 »

学习 Flink(六):检查点和保存点

更新至 Flink 1.8.0 检查点 检查点(Checkpoint)机制是 Flink 实现错误容忍机制的核心。通过持续以异步的方式保存轻量级的镜像,当错误(机器、网络或者软件原因)发生时,系统重启操作并重置操作到最新保存成功的检查点。 Flink 镜像参考论文:Lightweight Asynchronous Snapshots for Distributed Dataflows Flink »