Akka 和 Flink TaskManager 之间的关系



我是 Flink 的新手。

我刚刚在本地 PC 上安装了 Flink 并提交了 Flink 作业。在 Flink 网页 UITaskManagers菜单中,我可以看到path, id是"akka://flink/user/taskmanager"

我想知道这意味着什么。

Akka 和 Flink 之间的关系是 Flink 实现了一些内部组件作为 Akka actor:JobManagerTaskManagerJobClient。更多信息详见 Flink 文档。

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

相关内容

  • 没有找到相关文章