YARN 中对 Flink ACL 的支持

Question

在安全的 Hadoop 集群中，我尝试从 YARN 访问 Flink AM 页面和日志，并看到以下错误： User %remoteUser are not authorized to view application %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 问题。如果您能帮助实现它，社区会非常高兴。