0

我设置了 1 个名称节点、2 个数据节点、1 个资源管理器和 2 个节点管理器。所有组件都作为 docker 容器运行。每次我从 2 台机器(2 个客户端)执行 spark 提交(纱线集群模式)时,作业都会按顺序完成。Job1 和 Job2 都进入 Accepted 状态,Job1 变为 Running 和 Finished 状态,然后 Job2 被选中并完成其执行。这些作业有什么方法可以并行执行吗?应用程序管理器如何选择这些任务交给节点管理器?

4

1 回答 1

0

集群设置使用 YARN Capacity Scheduler,这是大多数可用 Hadoop 发行版的默认设置。如果同一用户提交了多个作业,它们将进入遵循 FIFO 的同一用户队列。这是容量调度程序的默认行为。

Fair Scheduler可以配置为通过共享可用资源并行运行作业。

将此属性添加到yarn-site.xml

<property>
  <name>yarn.resourcemanager.scheduler.class</name>
  <value>org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler</value>
</property>

queues在分配文件中配置公平调度程序,

<property>
      <name>yarn.scheduler.fair.allocation.file</name>
      <value>/path/to/allocation-file.xml</value>
</property>

如果未配置此属性,则默认为每个用户创建一个队列。

于 2017-02-01T19:20:59.490 回答