[I] [Bug] KubernetesClusterDescriptor not closed after use, cause the file handle resource leaks [incubator-streampark]

["jianjun159 (via GitHub)" <gi...@apache.org>]

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
   
   ![image](https://github.com/apache/incubator-streampark/assets/128395511/cefb85e3-a853-4850-86fe-bc6ce27f8cc1)
   
   
   ### 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: issues-unsubscribe@streampark.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [Bug] KubernetesClusterDescriptor not closed after use, cause the file handle resource leaks [incubator-streampark]

["caicancai (via GitHub)" <gi...@apache.org>]

caicancai closed issue #3667: [Bug] KubernetesClusterDescriptor not closed after use, cause the file handle resource leaks
URL: https://github.com/apache/incubator-streampark/issues/3667


-- 
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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org