You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "zhang (Jira)" <ji...@apache.org> on 2023/10/25 07:26:00 UTC

[jira] [Reopened] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

     [ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

zhang reopened FLINK-33355:
---------------------------

> can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.
> ---------------------------------------------------------------------------------
>
>                 Key: FLINK-33355
>                 URL: https://issues.apache.org/jira/browse/FLINK-33355
>             Project: Flink
>          Issue Type: Bug
>          Components: API / Core
>         Environment: flink 1.17.1
>            Reporter: zhang
>            Priority: Major
>
> If the program includes operators with window, it is not possible to reduce the parallelism of the operators from n to 1 when restarting from a savepoint, and it will result in an error: 
> {code:java}
> //IllegalStateException: Failed to rollback to checkpoint/savepoint Checkpoint Metadata. Max parallelism mismatch between checkpoint/savepoint state and new program. Cannot map operator 0e059b9f403cf6f35592ab773c9408d4 with max parallelism 128 to new program with max parallelism 1. This indicates that the program has been changed in a non-compatible way after the checkpoint/savepoint. {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)