单机standalone,还是Docker/K8s ?


这个异常出现的时机,与周期性的,还是跟CPU、内存,乃至网络流量变化相关?



在 2021-06-16 19:10:24,"yidan zhao" <hinobl...@gmail.com> 写道:
>Hi, yingjie.
>If the network is not stable, which config parameter I should adjust.
>
>yidan zhao <hinobl...@gmail.com> 于2021年6月16日周三 下午6:56写道:
>>
>> 2: I use G1, and no full gc occurred, young gc count: 422, time:
>> 142892, so it is not bad.
>> 3: stream job.
>> 4: I will try to config taskmanager.network.retries which is default
>> 0, and taskmanager.network.netty.client.connectTimeoutSec 's default
>> is 120s。
>> 5: I checked the net fd number of the taskmanager, it is about 1000+,
>> so I think it is a reasonable value.
>>
>> 1: can not be sure.
>>
>> Yingjie Cao <kevin.ying...@gmail.com> 于2021年6月16日周三 下午4:34写道:
>> >
>> > Hi yidan,
>> >
>> > 1. Is the network stable?
>> > 2. Is there any GC problem?
>> > 3. Is it a batch job? If so, please use sort-shuffle, see [1] for more 
>> > information.
>> > 4. You may try to config these two options: taskmanager.network.retries, 
>> > taskmanager.network.netty.client.connectTimeoutSec. More relevant options 
>> > can be found in 'Data Transport Network Stack' section of [2].
>> > 5. If it is not the above cases, it is may related to [3], you may need to 
>> > check the number of tcp connection per TM and node.
>> >
>> > Hope this helps.
>> >
>> > [1] 
>> > https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/ops/batch/blocking_shuffle/
>> > [2] 
>> > https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/deployment/config/
>> > [3] https://issues.apache.org/jira/browse/FLINK-22643
>> >
>> > Best,
>> > Yingjie
>> >
>> > yidan zhao <hinobl...@gmail.com> 于2021年6月16日周三 下午3:36写道:
>> >>
>> >> Attachment is the exception stack from flink's web-ui. Does anyone
>> >> have also met this problem?
>> >>
>> >> Flink1.12 - Flink1.13.1.  Standalone Cluster, include 30 containers,
>> >> each 28G mem.

回复