luchunliang opened a new issue, #11836:
URL: https://github.com/apache/inlong/issues/11836
### Description
1. Implement flow control in SortStandalone first to resolve current
frequent alert issues.
2. Enable flow control at the SortTask granularity:
1) Initial buffer size must be 1 data unit upon deployment.
2) After successful data transmission, the buffer size increases to
one-third of the default configuration value (configurable).
3. Trigger SortTask deactivation in the container if buffer size
utilization exceeds 80% capacity (configurable), and
failures to scale up within the current minute exceed 10 data units
(configurable). Force shutdown via kafkaClient.closeTimeout (ensuring
time-bound deactivation). Block SortTask reactivation for 5 minutes
(configurable).
### Use case
_No response_
### Are you willing to submit PR?
- [x] Yes, I am willing to submit a 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]
