The encryptor will be serialized and sent with the rest of your Job Graph when the job is submitted. If it’s not serializable you get an error.
Sent from my iPhone > On Aug 15, 2019, at 11:00 AM, Vishwas Siravara <vsirav...@gmail.com> wrote: > > 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
