wanggx opened a new issue, #4238:
URL: https://github.com/apache/streampark/issues/4238

   ### Search before asking
   
   - [x] I had searched in the 
[issues](https://github.com/apache/streampark/issues?q=is%3Aissue+label%3A%22improvement%22)
 and found no similar issues.
   
   
   ### Java Version
   
   
在k8s部署模式中,Runtime.getRuntime().availableProcessors()获取的是pod所在节点的核心数,这样会导致JVM中创建的线程过多,导致应用状态监控的线程无法正常执行,应用状态无法正常更新,并且随着Pod飘在不同的Kubelet
 Node节点,问题会偶现
   
   ### Scala Version
   
   2.11.x
   
   ### StreamPark Version
   
   2.0.0
   
   ### Flink Version
   
   flink1.16.3
   
   ### Deploy mode
   
   kubernetes-session
   
   ### What happened
   
   创建的线程过多,导致线程无法正常执行
   
   ### Error Exception
   
   ```log
   could not create native thread , cause by java.lang.OutofMemoryError
   ```
   
   ### Screenshots
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] 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]

Reply via email to