你好, 当前,Flink 支持根据现有的资源大小 (TaskManager 数量) 自动调整parallelism,但是添加或者减少 TaskManager 则必须手动操作,比如设计一个外部的监控系统根据某些指标判断增减TaskManager数量。这种模式也只支持 standalone的部署方式,所以native Kubernetes也是不支持的。
你可以阅读下下面的文档了解下更多 Flink 目前关于Elastic Scaling的尝试: https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/elastic_scaling/ <https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/elastic_scaling/> https://flink.apache.org/2021/05/06/reactive-mode.html > On 14 Aug 2022, at 10:38 AM, casel.chen <casel_c...@126.com> wrote: > > flink on k8s作业能否在给定资源范围内自动根据上游流量大小实现弹性扩缩容?例如增加并发度和TaskManager数量等