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
