Akka与Flink TaskManager的关系

Question

我是弗林克的新手。

我刚在本地电脑上安装了Flink，并提交了一份Flink作业。在Flink web UI TaskManagers菜单中，我可以看到path, id是"akka://flink/user/taskmanager“

我想知道这意味着什么。

Answer 1

Akka和Flink之间的关系是，Flink作为Akka参与者实现了一些内部组件：JobManager、TaskManager和JobClient。更多信息将在Flink文档中详细介绍。

字符串akka://flink/user/taskmanager是一个演员路径，它指示一个参与者驻留在参与者监督层次结构中的位置：flink是参与者系统的名称，user是所有用户创建的顶级参与者的守护参与者。TaskManager参与者直接位于守护者参与者的下方，这意味着TaskManager是通过ActorSystem.actorOf方法创建的顶级参与者。