我的团队正在尝试在Mesos/Marathon上设置Apache Flink(v1.4(集群。我们正在使用中间层提供的 docker 镜像。效果真的很好!
由于新的要求,任务管理器必须使用扩展运行时权限启动。我们可以通过马拉松 Web UI 轻松地为应用程序管理器启用此运行时权限。但是,我们找不到为任务管理器启用权限的方法。
在 Apache Spark 中,我们可以在 Spark 的配置文件中设置spark.mesos.executor.docker.parameters privileged=true
。因此,Spark 可以将此参数传递给docker run
命令。我想知道 Apache Flink 是否允许我们在启动任务管理器时将自定义参数传递给docker run
。如果没有,我们如何以扩展的运行时权限启动任务管理器?
谢谢
此提交中mesos.resourcemanager.tasks.container.docker.parameters
引入了一个新参数,该参数将允许将任意参数传递给 Docker。
不幸的是,目前这是不可能的(或者仅适用于 Tobi 指出的框架调度程序(。
我继续为此功能创建了一个 Jira,以便您可以跟踪/添加详细信息/自己贡献它:https://issues.apache.org/jira/browse/FLINK-8490
您应该能够调整 https://github.com/mesoshq/flink-framework/blob/master/index.js 的 ContainerInfo 中的参数设置以支持这一点。我最终会在 Docker 镜像中更新 Flink 版本......