[
https://issues.apache.org/jira/browse/FLINK-27748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543896#comment-17543896
]
Konstantin Knauf commented on FLINK-27748:
------------------------------------------
IIRC the adaptive scheduler (or at least reactive mode) already takes the max
parallelism for an operator into account. Could you use maxParallelism to
specify an upper bound?
cc [~chesnay]
> AdaptiveScheduler should support operator fixed parallelism
> -----------------------------------------------------------
>
> Key: FLINK-27748
> URL: https://issues.apache.org/jira/browse/FLINK-27748
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Task
> Reporter: john
> Priority: Minor
>
> In the job topology, if the user specifies the concurrency of the operator,
> AdaptiveScheduler should support the operator's maximum parallelism equal to
> the user-specified parallelism during the scheduling process. And the minimum
> parallelism is equal to the number of slots available to the cluster.
> This is especially useful in certain scenarios,
> For example, the parallelism of an operator that consumes Kafka is specified
> to be equal to the number of partitions. Or you want to control the write
> rate of the operator, etc.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
