se try to increase the thread pool for akka as written in my previous
> email and report back.
>
> On Mon, Jul 6, 2020 at 9:44 PM Mark Zitnik wrote:
>
>> Hi Benchao,
>>
>> i have run this in the code:
>>
>> println(env.getConfig.getAutoWatermarkInterval)
>
Operator is OK.
> There is one more config that might affect the throughput of
> AsyncOperator, it's watermark.
> Because unordered async operator still keeps the order between watermarks,
> did you use
> event time in your job, and if yes, what's the watermark interval in your
>
ime of per blocked rpc request
>
> Mark Zitnik 于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
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 no
