Re: Understanding job flow

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

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 <[hidden email]> 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