flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gary Yao (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-12126) Make relaxed rescaling behaviour accessible in REST interface
Date Fri, 26 Apr 2019 10:06:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-12126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826837#comment-16826837

Gary Yao commented on FLINK-12126:

[~jshs] ping

> Make relaxed rescaling behaviour accessible in REST interface
> -------------------------------------------------------------
>                 Key: FLINK-12126
>                 URL: https://issues.apache.org/jira/browse/FLINK-12126
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / REST
>    Affects Versions: 1.7.2
>            Reporter: Joshua Schneider
>            Priority: Minor
> The REST handler for rescaling uses RescalingBehaviour.STRICT as a hard-coded parameter.
This has the following consequences when a job is rescaled:
>  * All operators are set to the new parallelism. If at least one operator's max parallelism
is less than the new parallelism, the rescale operation is aborted.
>  * Therefore, it is impossible to restrict the parallelism of a subset of operators (say,
to one) in combination with rescaling.
> A different behaviour which fixes these issues, RescalingBehaviour.RELAXED, is already
provided by the internal API. However, it appears to be unused.
> The REST interface should provide a parameter that selects the strategy. Alternatively,
it could be a setting of the job.

This message was sent by Atlassian JIRA

View raw message