Mesos设置

译者：flink.sojb.cn

背景

Mesos实现包含两个组件：Application Master和Worker。Worker是简单的TaskManagers，它们由应用程序主机设置的环境进行参数化。Mesos实现中最复杂的组件是应用程序主机。应用程序主机当前托管以下组件：

Mesos调度程序

调度程序负责向Mesos注册框架，请求资源和启动工作节点。调度程序不断需要向Mesos报告以确保框架处于健康状态。为了验证群集的运行状况，调度程序监视生成的worker并将其标记为失败，并在必要时重新启动它们。

Flink的Mesos调度程序本身目前不具备高可用性。但是，它会在Zookeeper中保存有关其状态（例如配置，工作者列表）的所有必要信息。在出现故障时，它依赖于外部系统来启动新的调度程序。然后，调度程序将再次向Mesos注册并完成协调阶段。在协调阶段，调度程序接收正在运行的工作程序节点的列表。它将这些与Zookeeper中恢复的信息进行匹配，并确保在故障之前将群集恢复到状态。

工件服务器

工件服务器负责向工作节点提供资源。资源可以是从Flink二进制文件到共享机密或配置文件的任何内容。例如，在非容器化环境中，工件服务器将提供Flink二进制文件。将提供哪些文件取决于使用的配置覆盖。

Flink的调度程序和Web界面

Dispatcher和Web界面为监视，作业提交和其他客户端与群集的交互提供了一个中心点（请参阅FLIP-6）。

启动脚本和配置叠加层

启动脚本提供了一种配置和启动应用程序主机的方法。然后，工作节点继承所有进一步的配置。这是使用配置叠加来实现的。配置覆盖提供了一种从环境变量和配置文件推断配置的方法，这些配置文件将发送到工作节点。

DC / OS

本节涉及DC / OS，它是具有复杂应用程序管理层的Mesos分发。它预装了Marathon，这是一种监控应用程序并在发生故障时保持其状态的服务。

如果您没有正在运行的DC / OS群集，请按照如何在官方网站上安装DC / OS的 说明进行 算子操作。

拥有DC / OS群集后，您可以通过DC / OS Universe安装Flink。在搜索提示中，只需搜索Flink。或者，您可以使用DC / OS CLI：

  1. dcos package install flink

更多信息可以在 DC / OS示例文档中找到。

没有DC / OS的Mesos

您也可以在没有DC / OS的情况下运行Mesos。

安装Mesos

请按照官方网站上如何设置Mesos的说明进行 算子操作。

安装后，您必须通过创建文件MESOS_HOME/etc/mesos/masters和配置主节点和代理节点集MESOS_HOME/etc/mesos/slaves。这些文件在每一行中包含一个主机名，相应的组件将在该主机名上启动（假设SSH访问这些节点）。

接下来，您必须创建MESOS_HOME/etc/mesos/mesos-master-env.sh或使用在同一目录中找到的模板。在此文件中，您必须定义

  1. export MESOS_work_dir=WORK_DIRECTORY

并建议取消注册

  1. export MESOS_log_dir=LOGGING_DIRECTORY

要配置Mesos代理，您必须创建MESOS_HOME/etc/mesos/mesos-agent-env.sh或使用在同一目录中找到的模板。你必须配置

  1. export MESOS_master=MASTER_HOSTNAME:MASTER_PORT

并取消注释

  1. export MESOS_log_dir=LOGGING_DIRECTORY
  2. export MESOS_work_dir=WORK_DIRECTORY

Mesos类库

要使用Mesos运行Java应用程序，必须MESOS_NATIVE_JAVA_LIBRARY=MESOS_HOME/lib/libmesos.so在Linux 上导出。在Mac OS X下，您必须导出MESOS_NATIVE_JAVA_LIBRARY=MESOS_HOME/lib/libmesos.dylib。

部署Mesos

要启动mesos群集，请使用部署脚本MESOS_HOME/sbin/mesos-start-cluster.sh。要停止mesos群集，请使用部署脚本MESOS_HOME/sbin/mesos-stop-cluster.sh。有关部署脚本的更多信息，请访问此处。

安装Marathon

或者，您也可以安装Marathon，使您能够以高可用性（HA）模式运行Flink 。

预安装Flink与Docker / Mesos容器

您可以在所有Mesos主节点和代理节点上安装Flink。您还可以在部署期间从Flink网站提取二进制文件，并在启动应用程序主服务器之前应用自定义配置。更方便，更易于维护的方法是使用Docker容器来管理Flink二进制文件和配置。

这是通过以下配置条目控制的：

  1. mesos.resourcemanager.tasks.container.type: mesos _or_ docker

如果设置为“docker”，请指定镜像名称：

  1. mesos.resourcemanager.tasks.container.image.name: image_name

独立

在/binFlink发行版的目录中，您可以找到两个启动脚本来管理Mesos集群中的Flink进程：

  1. mesos-appmaster.sh 这将启动Mesos应用程序主机，它将注册Mesos调度程序。它还负责启动工作节点。

  2. mesos-taskmanager.sh Mesos工作进程的入口点。您不需要显式执行此脚本。它由Mesos工作节点自动启动以启动新的TaskManager。

为了运行mesos-appmaster.sh脚本，你必须定义mesos.master在flink-conf.yaml或通过它传递-Dmesos.master=...给Java进程。

执行时mesos-appmaster.sh，它将在您执行脚本的机器上创建一个JobManager。与此相反，TaskManager将作为Mesos集群中的Mesos任务运行。

一般配置

可以通过传递给Mesos应用程序主机的Java属性完全参数化Mesos应用程序。这还允许指定常规Flink配置参数。例如：

  1. bin/mesos-appmaster.sh \
  2.     -Dmesos.master=master.foobar.org:5050 \
  3.     -Djobmanager.heap.mb=1024 \
  4.     -Djobmanager.rpc.port=6123 \
  5.     -Drest.port=8081 \
  6.     -Dmesos.resourcemanager.tasks.mem=4096 \
  7.     -Dtaskmanager.heap.mb=3500 \
  8.     -Dtaskmanager.numberOfTaskSlots=2 \
  9.     -Dparallelism.default=10

注意：如果Flink处于传统模式，则还应定义由Mesos via启动的TaskManager的数量 mesos.initial-tasks。

高可用性

您将需要运行Marathon或Apache Aurora之类的服务，该服务负责在节点或进程出现故障时重新启动Flink主进程。此外，还需要像Flink文档的“ 高可用性”部分中所述配置Zookeeper 。

Marathon

需要设置Marathon才能启动bin/mesos-appmaster.sh脚本。特别是，它还应调整Flink群集的任何配置参数。

以下是Marathon的示例配置：

  1. {
  2.     "id": "flink",
  3.     "cmd": "$FLINK_HOME/bin/mesos-appmaster.sh -Djobmanager.heap.mb=1024 -Djobmanager.rpc.port=6123 -Drest.port=8081 -Dmesos.resourcemanager.tasks.mem=1024 -Dtaskmanager.heap.mb=1024 -Dtaskmanager.numberOfTaskSlots=2 -Dparallelism.default=2 -Dmesos.resourcemanager.tasks.cpus=1",
  4.     "cpus": 1.0,
  5.     "mem": 1024
  6. }

使用Marathon运行Flink时，包含JobManager的整个Flink集群将作为Mesos集群中的Mesos任务运行。

配置参数

有关Mesos特定配置的列表，请参阅 配置文档的Mesos部分。