Auto-scaling for Flink Hudi sink tasks
- Dominant language
- Java
- Stars
- 6.2k
- Forks
- 2.5k
- Avg merge
- 2d 8h
- Merged PRs (30d)
- 111
Description
Currently the flink write task parallelism is set up through
{code:java}
write.tasks{code}
it is kind of a fixed number during the lifecycle of the ingestion pipeline, while for streaming, there are always fluctuation of the workload, it is great if we can tune the parallelism of write tasks based on the job load profile dynamically.
On K8s, Flink provides a [https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/custom-resource/autoscaler/] which is suitable for the purpose, which deserves a further investigation.
## JIRA info
- Link: https://issues.apache.org/jira/browse/HUDI-7574
- Type: Improvement
- Fix version(s):
- 1.2.0
---
## Comments
09/Apr/24 01:45;vinoth;We need to rethink these singleton tasks like cleaning etc. ;;;
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.