??????????????????
??????
??????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  183MB  207MB  232MB  
256MB 280MB 352MB  372MB
????????????????????????????????TM metaspace oom



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


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

回复