大家好,

目前测试的版本是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

 

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



回复