学习 Flink(九):Async I/O

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

学习 Flink(七):Flink on YARN

Flink 支持多种集群部署: Standalone Flink on YARN Flink on Mesos Flink on K8s 等等…… Flink on YARN 支持两种模式: 会话模式(Session Mode),在 YARN 上运行长期运行的 Flink 集群; 任务模式( »