Re: Asynchronous I/O poor performance

Posted by Benchao Li-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Fwd-Asynchronous-I-O-poor-performance-tp36382p36385.html

Hi Mark,

Could you give more details about your Flink job?

- the capacity of AsyncDataStream

- the parallelism of AsyncDataStream operator

- the time of per blocked rpc request

Mark Zitnik <[hidden email]> 于2020年7月5日周日 上午3:48写道：

Hi 

 

In my flink application I need to enrich data using AsyncDataStream.unorderedWait but I am getting poor perforce at the beginning I was just working with http call, but I have switched to grpc, I running on 8 core node and getting total of 3200 events per second my service that I am using is not fully utilized and can produce up to 10000 req/seq

Flink job flow 

Reading from Kafka ~> some enrichment with unoderedwait ~> map ~> write to Kafka 

Using Akkad grpc code written in scala 

Thanks

--