RE: [E] RE: Recommendations on using multithreading in flink map functions in java

@gmail.com>>; user@flink.apache.org<mailto:user@flink.apache.org>; dominik.buen...@swisscom.com<mailto:dominik.buen...@swisscom.com> Subject: Re: [E] RE: Recommendations on using multithreading in flink map functions in java ⚠EXTERNAL MESSAGE – CAUTION: Think Before You Click ⚠ Thanks R

Re: [E] RE: Recommendations on using multithreading in flink map functions in java

D0WaqFZfknkd-7hl-VgoNQ_l5tszcDDoP-vY4yBoLTIBRev_Iqtkyrei7vIQtduLckRXkz5Q3SIo42ZmYhhONov02b1Cl1g$> > > > > > > > > *From:* liu ron > *Sent:* Dienstag, 15. August 2023 03:54 > *To:* Vignesh Kumar Kathiresan > *Cc:* user@flink.apache.org > *Subject:* Re: Reco

RE: Recommendations on using multithreading in flink map functions in java

: Vignesh Kumar Kathiresan Cc: user@flink.apache.org Subject: Re: Recommendations on using multithreading in flink map functions in java Hi, Vignesh Flink is a distributed parallel computing framework, each MapFunction is actually a separate thread. If you want more threads to process the data, you

Re: Recommendations on using multithreading in flink map functions in java

Hi, Vignesh Flink is a distributed parallel computing framework, each MapFunction is actually a separate thread. If you want more threads to process the data, you can increase the parallelism of the MapFunction without having to use multiple threads in a single MapFunction, which in itself violate