Understanding job flow

Posted by Vishwas Siravara on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Understanding-job-flow-tp29435.html

Hi guys,

I have a map job where I want to encrypt certain keys . I initialize the encryptor in the main method and apply it in the map function. How is this encryptor shared when I have my job running on multiple task managers with parallelism > 1 ? 

Thanks,

Vishwas