Hello:
we are trying to test out Autoscaler in Flink Kubernetes Operator, and found that Autoscaler seems only works with Application Deployments✅, not in Session Cluster Deployments❌.
Can anyone help confirm this is expected behavior? Thanks!
g
Gyula Fóra
03/31/2023, 7:01 AM
Yes this is expected in the current state .
y
Yufei Chen
03/31/2023, 3:22 PM
@Gyula Fóra Thanks for confirm! May I know if there’s plan to support session cluster deployments?
g
Gyula Fóra
03/31/2023, 3:27 PM
The autoscaler algorithm deals with individual jobs. We can definitely extend this to SessionJobs but it doesn’t really make sense for session clusters directly
Gyula Fóra
03/31/2023, 3:28 PM
I think the session job support can be added once we upgrade the Flink client to 1.17 in the operator, we usually do this when the first patch version is released (1.17.1)
y
Yufei Chen
03/31/2023, 3:30 PM
Thanks, good to know session job support is in roadmap👍
For support session cluster deployment, I mean to make autoscaler work on SessionJobs that are submitted to Session Cluster.