我可以在flink cli和作业管理器之间使用什么身份验证方法?或者有哪些插件api可以在我自己的身份验证解决方案中使用,而不必对cli和后端进行黑客攻击和重建?
ymdaylpp1#
cli通过http与集群通信。您可以在cli和群集[1]之间配置ssl相互身份验证。如果需要更复杂的身份验证或授权选项,用户文档建议在集群前面部署一个代理[1]。但是,目前不可能使用身份验证扩展客户机[2][3],因此您可能必须编写自己的客户机。[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/security-ssl.html#external--rest连接[2] https://github.com/apache/flink/blob/8f8e35815c917616f98c13d056f20fefe36098f3/flink-clients/src/main/java/org/apache/flink/client/program/rest/restclusterclient.java[3] https://github.com/apache/flink/blob/8f8e35815c917616f98c13d056f20fefe36098f3/flink-runtime/src/main/java/org/apache/flink/runtime/rest/restclient.java
1条答案
按热度按时间ymdaylpp1#
cli通过http与集群通信。您可以在cli和群集[1]之间配置ssl相互身份验证。如果需要更复杂的身份验证或授权选项,用户文档建议在集群前面部署一个代理[1]。但是,目前不可能使用身份验证扩展客户机[2][3],因此您可能必须编写自己的客户机。
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/security-ssl.html#external--rest连接
[2] https://github.com/apache/flink/blob/8f8e35815c917616f98c13d056f20fefe36098f3/flink-clients/src/main/java/org/apache/flink/client/program/rest/restclusterclient.java
[3] https://github.com/apache/flink/blob/8f8e35815c917616f98c13d056f20fefe36098f3/flink-runtime/src/main/java/org/apache/flink/runtime/rest/restclient.java