dinky
dinky copied to clipboard
[Bug] [core] SessionPool中的push操作 executorList.size() >= FlinkConstant.DEFAULT_SESSION_COUNT 此处未生效
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
add session executor push operation, this code judge is not execute forever [executorList.size() >= FlinkConstant.DEFAULT_SESSION_COUNT]
What you expected to happen
detele
How to reproduce
doesn't work
Anything else
No response
Version
dev
Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct
Yes, welcome to optimize.
session already removed in 1.0