jianjun159 opened a new issue, #3667: URL: https://github.com/apache/incubator-streampark/issues/3667
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### Java Version jdk-8 ### Scala Version 2.12.x ### StreamPark Version release-2.1.2 ### Flink Version flink-1.18.1 ### deploy mode kubernetes-application ### What happened KubernetesClusterDescriptor not closed after use, cause the file handle resource leaks, file handle more than after the file handle system Settings, following a series of and open the file all related function abnormal, affect the use of the system Change the corresponding code in newFlinkClusterClient in KubernetesRetriever Original code ``` Try { clusterProvider .retrieve(flinkConfig.getString(KubernetesConfigOptions.CLUSTER_ID)) .getClusterClient } match { case Success(v) => Some(v) case Failure(e) => logError(s"Get flinkClient error, the error is: $e") None } ``` modified ``` try { Try { clusterProvider .retrieve(flinkConfig.getString(KubernetesConfigOptions.CLUSTER_ID)) .getClusterClient } match { case Success(v) => Some(v) case Failure(e) => logError(s"Get flinkClient error, the error is: $e") None } } finally { Utils.close(clusterProvider) } ``` ### Error Exception _No response_ ### Screenshots  ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR!(您是否要贡献这个PR?) ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
