Hi Vinay, it's not only done by enabling encryption of the Akka messages since the TaskManager to TaskManager communication utilizes Netty. There is a JIRA issue which tracks the progress on implementing secured communication within Flink: https://issues.apache.org/jira/browse/FLINK-3931. Feel free to get involved there.
Cheers, Till On Thu, Aug 25, 2016 at 8:51 PM, Vinay Patil <vinay18.pa...@gmail.com> wrote: > Hi, > > I have a requirement that all the data flowing between the task managers > should be encrypted, is there a way in Flink to do that. > > Can we use the configuration file to enable this as follows : > http://doc.akka.io/docs/akka/snapshot/scala/remoting.html#Remoting_Sample > > or do we need to add the above configurations in code here : > https://github.com/apache/flink/blob/master/flink- > runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala > > I have looked at this mail thread , but wanted to get clear understanding > of how we can achieve it > http://mail-archives.apache.org/mod_mbox/flink-user/201601.mbox/%3CCANC1h_ > v0pqfvfto478ft5cbgm-bf-do742gouz528bw7vrj...@mail.gmail.com%3E > > > > Regards, > Vinay Patil >
