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

Roman Khachatryan updated FLINK-23252:
--------------------------------------
    Summary: Support recovery after disabling changelog backend  (was: Support 
recovery with "changelog.enabled" altered)

> Support recovery after disabling changelog backend
> --------------------------------------------------
>
>                 Key: FLINK-23252
>                 URL: https://issues.apache.org/jira/browse/FLINK-23252
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / State Backends
>            Reporter: Roman Khachatryan
>            Priority: Major
>             Fix For: 1.14.0
>
>
> Currently, recovery from savepoint with changelog.enabled altered is not 
> supported (an exception will be thrown because of wrong state handle type).
>  
> It can be implemented by: * {{disabled -> enabled}} : load materialized state 
> with empty non-materialized
>  * {{enabled -> disabled}}: in {{changelog.snapshot()}} , call 
> {{underlyingBackend.snapshot()}} (instead of {{writer.persist()}}) if 
> savepoint



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to