分布式架构

有状态函数部署由几个相互作用的组件组成。在这里，我们将描述这些组件及其相互之间的关系以及Apache Flink运行时。

高级视图

有状态函数部署由一组Apache Flink有状态函数进程和执行远程函数的各种部署(可选)组成。

Flink工作进程（TaskManagers）从入口系统（Kafka，Kinesis等）接收事件，并将其路由到目标函数。它们调用函数并将结果消息路由到下一个各自的目标功能。指定用于出口的消息将被写入出口系统（再次，Kafka，Kinesis等）。

繁重的工作由Apache Flink进程完成，该进程管理状态，处理消息传递并调用有状态功能。Flink群集通常由一个主服务器和多个工作器（TaskManagers）组成。

除了Apache Flink流程之外，完整部署还需要ZooKeeper（用于主故障转移）和大容量存储（S3，HDFS，NAS，GCS，Azure Blob存储等）来存储Flink的检查点。反过来，部署不需要数据库，Flink进程也不需要持久卷。

有关详细信息，请参阅Python SDK和远程模块上的文档。

Last updated 3 years ago