Flink

Actor system(Akka) in Flink

2018-08-18  本文已影响179人  远o_O

一、概述

Flink's distributed execution consists of two important processes, master and worker. When a Flink program is executed, various processes take part in the execution, namely Job Manager, Task Manager, and Job Client.

image.png

Flink程序需要提交给Job Client。然后,Job Client将作业提交给Job Manager。Job Manager负责协调资源分配和作业执行。它首先要做的是分配所需的资源。资源分配完成后,任务将提交给相应的Task Manager。当接收到任务时, Task Manager启动一个线程以开始执行。执行到位时,Task Manager会继续向Job Manager报告状态更改。可以有各种状态,例如开始执行,正在进行或已完成。作业执行完成后,结果将发送回客户端。

二、Job Manager

2.1: Actor system(参与者系统)

Actor system是具有各种角色的actor的容器。它提供诸如调度,配置,日志记录等服务。它还包含一个启动所有actor的线程池。所有actors都位于层次结构中。每个新创建的actor都将分配给父级。actor使用消息传递系统相互交谈。每个actor都有自己的邮箱,从中读取所有邮件。如果actor是本地的,则消息通过共享内存共享,但如果actor是远程的,则通过RPC调用传递消息。

每位家长负责监督其子女。如果children发生任何错误,父母会收到通知。如果actor可以解决自己的问题,那么它可以重新启动它的子节点。如果它无法解决问题,那么它可以将问题升级到自己的父级:


Actor system in Flink

在Flink中,actor是具有状态和行为的容器。 actor的线程依次持续处理它将在其邮箱中接收的消息。其状态和行为由它收到的消息决定。

上一篇 下一篇

猜你喜欢

热点阅读