Hi Benchao The capacity is 100 Parallelism is 8 Rpc req is 20ms
Thanks On Sun, 5 Jul 2020, 6:16 Benchao Li, <libenc...@apache.org> wrote: > 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 <mark.zit...@gmail.com> 于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 >> > > > -- > > Best, > Benchao Li >
