我在学习Flink，我在执行一些小程序。我看到有许多过程与Flink有关。当我启动集群时，它启动作业管理器和任务管理器的进程，然后它们执行自己的程序。当我启动应用程序时，它会启动一个新的进程。在任务管理器的进程中有一个执行任务的槽，但是新进程做什么呢？
s8vozzvw1#
一般来说，最终有多少进程取决于如何执行flink。既然你提到了集群，我假设你在集群模式下运行flink。那么您的新进程就是concept/runtime页面上描述的客户机进程。此客户端将用户代码和配置提交给jobmanager，并定期轮询作业结果以等待作业完成/失败（如果配置为等待）。不过，这个过程基本上是空转的。
1条答案
按热度按时间s8vozzvw1#
一般来说，最终有多少进程取决于如何执行flink。既然你提到了集群，我假设你在集群模式下运行flink。那么您的新进程就是concept/runtime页面上描述的客户机进程。
此客户端将用户代码和配置提交给jobmanager，并定期轮询作业结果以等待作业完成/失败（如果配置为等待）。不过，这个过程基本上是空转的。