资源管理器何时联系name node,在代码中的何处可以找到它?

e0bqpujr  于 2021-06-01  发布在  Hadoop
关注(0)|答案(0)|浏览(225)

我的问题与实际代码更相关。我正在开发hadoop2.7.7。
我似乎明白,在客户端提交应用程序之后,资源管理器必须分配一个应用程序主机来处理该应用程序。
此时,当资源管理器与name节点通信以获取处理所需文件的元数据时,此通信位于哪个包和类?
编辑:目前我正在查看org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo包中的fifoscheduler.java。方法private void assigncontainers(ficasschedulernode node)从请求为节点启动容器的应用程序的fifo列表中选择应用程序。所以从逻辑上说,我相信当fifoscheduler从fifo列表中选择应用程序时,rm已经在列表中拥有了ay应用程序所需的文件/文件位置的信息。我查看了fifoscheduler.java中前面提到的assigncontainers()方法的调用层次结构中的所有方法,没有找到rm在何处/何时接收到应用程序所需的文件(或文件元数据)信息的线索。
这是我所能描述的最好的代码。如果你需要任何额外的信息,我很乐意提供。如果不清楚,我道歉。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题