Kerberos 动态参数认证问题

[silence-2]

大家好，

目前测试的版本是flink1.11

看jira https://issues.apache.org/jira/browse/FLINK-12130 所示的问题好像并没有得到解决

flink run -m yarn-cluster -yD security.kerberos.login.keytab = / path / to / keytab -yD security.kerberos.login.principal = xxx /path/to/test.jar

 

看源码发现安全认证所用的配置还是只使用了配置文件中的配置，并没有把动态参数里的配置进行合并，求助~

[caozhen]

我的解决方式是改下 flink 的源码。

把参数 CliFrontend的args 传给 FlinkYarnSessionCli 类。并将args中的这些kv赋给configuration。

再重新打dist包



--
Sent from: http://apache-flink.147419.n8.nabble.com/