??????????????Job??????TaskManager ??????oom?

[????????]

??????????????????????




------------------ ???????? ------------------
??????:                                                                         
                                               "????????"                       
                                                             
<chenliangv...@qq.com&gt;;
????????:&nbsp;2022??5??18??(??????) ????10:45
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;????????Job??????TaskManager ??????oom?



??????????????????
??????
??????Flink 1.14
????????standalone ????????????Flink job??supervisorctl??????JM??TM??systemd????


??????
job????????????????????flink??????????restart-strategy.fixed-delay.attempts: 2??
??????????????????????????????????????????job????????????????supervisorctl????????job????????????????????
TM????????????OOM(??????????????????????????????????????)??????TM????????????????????TM??????????????????job??????TM??????????????????????TM??Systemd??????????TM??????????????
????????????????????????????????standalone??????????????TM??


??????
TM??????????TM metaspace oom
JM??????Association with remote system [akka.tcp://flink@localhost:43583] has 
failed, address is now gated for [50] ms. Reason: [Association failed with 
[akka.tcp://flink@localhost:43583]] Caused by: [java.net.ConnectException: 
Connection refused: localhost/127.0.0.1:43583]
JM ???? TM??????????unreachable



??????
????????????????????????512M????????????
????????????job????????
????tm metaspace ??????????179MB&nbsp; 183MB&nbsp; 207MB&nbsp; 232MB&nbsp; 
256MB 280MB 352MB&nbsp; 372MB
????????????????????????????????TM metaspace oom



??????
1.??????TM??????oom????????????????job??????????job??????????????????
2.TM??????OOM????????????JM????TM??????TM????????????????


????????????????
1.????????????
2.????????????????standalone??????????????TM??????????????????????????????????????????????????????