在mesos/marathon上运行flink时向docker传递自定义参数

dxxyhpgq  于 2021-06-26  发布在  Mesos
关注(0)|答案(3)|浏览(440)

我的团队正在尝试在mesos/marathon上设置ApacheFlink(v1.4)集群。我们使用的是中层提供的docker图像。它工作得很好!
由于新的需求,任务管理器必须以扩展运行时权限启动。我们可以通过marathonwebui轻松地为appmanager启用这个运行时特权。但是,我们找不到为任务管理器启用权限的方法。
在apache spark中,我们可以设置 spark.mesos.executor.docker.parameters privileged=true 在spark的配置文件中。因此,spark可以将此参数传递给 docker run 命令。我想知道apache flink是否允许我们将自定义参数传递给 docker run 启动任务管理器时。如果没有,我们如何用扩展的运行时权限启动任务管理器?
谢谢

bhmjp9jg

bhmjp9jg1#

不幸的是,目前还不可能做到这一点(或者只针对tobi指出的框架调度器)。
我继续为这个特性创建了一个jira,这样你就可以跟踪/添加细节/自己贡献:https://issues.apache.org/jira/browse/flink-8490

q3aa0525

q3aa05252#

有一个新参数 mesos.resourcemanager.tasks.container.docker.parameters 在这个commit中引入了允许向docker传递任意参数的方法。

mwkjh3gx

mwkjh3gx3#

您应该能够调整的containerinfo中参数的设置https://github.com/mesoshq/flink-framework/blob/master/index.js 为了支持这一点。我最终会在docker图像中更新flink版本。。。

相关问题