[
https://issues.apache.org/jira/browse/FLINK-25921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895532#comment-17895532
]
Fabian Paul commented on FLINK-25921:
-------------------------------------
[~poorvank] I assigned the ticket to you. Do you already have a use case or
reproduction of how the current behavior causes issues?
> Support different input parallelism for preCommit topology
> ----------------------------------------------------------
>
> Key: FLINK-25921
> URL: https://issues.apache.org/jira/browse/FLINK-25921
> Project: Flink
> Issue Type: Sub-task
> Components: API / DataStream
> Affects Versions: 1.15.0, 1.16.0
> Reporter: Fabian Paul
> Assignee: Poorvank Bhatia
> Priority: Major
>
> Currently, we assume that the pre-commit topology has the same parallelism as
> the operator before when inserting the failover region. To support a
> different parallelism we might need to insert a different identity map to
> customize the mapping.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
