Hello Everyone, How do I set maxParallelism for a sink operator? , I am using flink operator autoscaler feature and just setting global maxParallelism is scaling sink to much higher parallelism. I want to avoid this.

If you don’t want to scale your sink there is a config to exclude some vertices from the autoscaler

kubernetes.operator.job.autoscaler.vertex.exclude.ids What will be vertexId here. Vertex Id is assigned by flink at runtime right? How can user get the vertex id

You can check this on the Flink ui for example , not the most user friendly feature but we don’t have anything better at the moment

sure thanks