【Flink】Flink 运行架构及 Flink 流处理 API

一、Flink 的运行时组件 Flink 运行时架构主要包括四个不一样的组件，它们会在运行流处理应用程序时协同工做：做业管理器（JobManager）、资源管理器（ResourceManager）、任务管理器（TaskManager），以及分发器（Dispatcher）。由于 Flink 是用 Java 和 Scala 实现的，因此全部组件都会运行在Java 虚拟机上。每一个组件的职责以下： we

>>阅读原文<<