Does Flink cluster security works in Flink 1.1.4 release?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Does Flink cluster security works in Flink 1.1.4 release?

Zhangrucong

Hi:

     Now I use Flink 1.1.4 release in standalone cluster model. I want to do the Kerberos authentication between Flink CLI and the Jobmanager. But in the flink-conf.yaml, there is no Flink cluster security configuration.

Does the Kerberos authentication works in Flink 1.1.4 release?

Thanks in advance!

 

Reply | Threaded
Open this post in threaded view
|

Re: Does Flink cluster security works in Flink 1.1.4 release?

Stephan Ewen
Hi!

Flink 1.1.x supports Kerberos for Hadoop (HDFS, YARN, HBase) via Hadoop's ticket system. It should work via kinit, in the same way when submitting a secure MapReduce job.

Kerberos for ZooKeeper, Kafka, etc, is only part of the 1.2 release.

Greetings,
Stephan


On Wed, Jan 4, 2017 at 7:25 AM, Zhangrucong <[hidden email]> wrote:

Hi:

     Now I use Flink 1.1.4 release in standalone cluster model. I want to do the Kerberos authentication between Flink CLI and the Jobmanager. But in the flink-conf.yaml, there is no Flink cluster security configuration.

Does the Kerberos authentication works in Flink 1.1.4 release?

Thanks in advance!