Fabian Paul created FLINK-25921: ----------------------------------- Summary: 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
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.1#820001)