turtlebin created FLINK-24369:
---------------------------------
Summary: Resource Leak may happen if flink cluster runs abnormally
and repeatedly retry
Key: FLINK-24369
URL: https://issues.apache.org/jira/browse/FLINK-24369
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 1.13.0
Reporter: turtlebin
I encountered a problem in the process of integrating Flink and Redisson. When
the task encounters abnormalities and keeps retries, it will cause the number
of Redis Clients to increase volatility (sometimes the number increases,
sometimes the number decreases, but the overall trend is growth). Even if I
shutdown the Redisson Instance by overwriting the close function , the number
of Redis-Clients cannot be prevented from continuing to grow, and eventually
the number of Clients will reach the upper limit and an error will be thrown.
Moreover, this situation only occurs in the Flink cluster operation mode with
version 1.13.0 or above, and the number of Redis-Clients will remain stable in
the local mode or in the cluster mode with version under1.12. The test code is
below. I wonder if you can provide specific reasons and solutions for this
situation, thank you.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
