我正在研究Flink,并且正在执行一些程序。我看到有很多与Flink相关的过程。当我启动集群时,它将启动作业管理器和任务管理器的过程,然后他们执行程序。当我启动应用程序时,它开始一个新的过程。在任务管理器的过程中,有一个插槽可以执行任务,但是新过程会做什么?
通常,最终有多少个进程取决于您如何执行Flink。既然您提到了集群,我假设您在集群模式下运行Flink。然后,您的新进程就是concept/runtime页面上描述的客户端进程。
此客户端将用户代码和配置提交给作业管理器,并定期轮询作业结果以等待作业完成/失败(如果配置为等待)。但是,该过程通常处于空闲状态。