hadoop - 在 YARN 中支持 Flink ACL

Question

在安全的 Hadoop 集群中，我尝试从 YARN 访问 Flink AM 页面和日志，并看到以下错误:用户 %remoteUser 无权查看应用程序 %appID

看来是因为Flink这边不支持YARN中的ACL。

代码是如何工作的

消息来自使用 ApplicationACLsManager 类的 hadoop/yarn/server/AppBlock 类。此类执行检查并引用在 RMAppManager 中设置的应用程序信息:

this.applicationACLsManager.addApplication(applicationId,
submissionContext.getAMContainerSpec().getApplicationACLs()

AMContainerSpec 是ContainerLaunchContext 类，具有PB 实现，从框架端提交。

在 Flink 中，这个对象是在 AbstractYarnClusterDescriptor 类中创建的，该类(以及 Flink 中的其他类)不调用 setApplicationACLs。

问题

有没有办法绕过这个或者正确的解决方案是贡献对 Flink 的支持？ Flink 端这个特性的状态如何？

Answer 1

这听起来像是我们应该修复的 Flink 中的一个限制。请打开一个 JIRA 问题。如果您能帮助实现它，社区会非常高兴。