apache / apache/hudi

Auto-scaling for Flink Hudi sink tasks

Open
#16,439 0 comments 0 reactions 1 assignee Claimed by @cshuo View on GitHub
engine:flink priority:medium type:improvement
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.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.