我是 Flink 的新手。
我刚刚在本地 PC 上安装了 Flink 并提交了 Flink 作业。在 Flink 网页 UITaskManagers
菜单中,我可以看到path, id
是"akka://flink/user/taskmanager"
我想知道这意味着什么。
Akka 和 Flink 之间的关系是 Flink 实现了一些内部组件作为 Akka actor:JobManager
、TaskManager
和JobClient
。更多信息详见 Flink 文档。
字符串akka://flink/user/taskmanager
是一个 actor 路径,它指示 actor 在 actor 监督层次结构中的位置:flink
是 actor 系统的名称,user
是所有用户创建的顶级 actor 的守护者 actor。TaskManager
演员位于守护演员的正下方,这意味着TaskManager
是通过ActorSystem.actorOf
方法创建的顶级演员。