[
https://issues.apache.org/jira/browse/FLINK-26093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-26093:
--------------------------------------
Description:
The test vaildates corrects types of state handles created by savepoint. For
NATIVE savepoints, it expects IncrementalRemoteKeyedStateHandle and
KeyGroupsStateHandle.
However, with changelog those will be wrapped into ChangelogStateBackendHandle
and the test fails.
It can be refactored to account for changelog.
was:
The test vaildates corrects types of state handles created by savepoint. For
NATIVE savepoints, it expects IncrementalRemoteKeyedStateHandle and
KeyGroupsStateHandle.
However, with changelog those will be wrapped into ChangelogStateBackendHandle
and the test fails.
It can be refactored to account for changelog.
cc: [~dwysakowicz],
----
Another issue is that it does NOT fail on master where
checkpointing.changelog=random in pom.xml which should call
{code:java}
randomize(conf, ENABLE_STATE_CHANGE_LOG, true, false);{code}
If I leave only a single "true" option to randomize(), it does fail. If
confirmed, I'll open a new ticket for that. cc: [~arvid]
> SavepointFormatITCase fails with ChangelogStateBackend
> ------------------------------------------------------
>
> Key: FLINK-26093
> URL: https://issues.apache.org/jira/browse/FLINK-26093
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 1.15.0
> Reporter: Roman Khachatryan
> Assignee: Roman Khachatryan
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> The test vaildates corrects types of state handles created by savepoint. For
> NATIVE savepoints, it expects IncrementalRemoteKeyedStateHandle and
> KeyGroupsStateHandle.
> However, with changelog those will be wrapped into
> ChangelogStateBackendHandle and the test fails.
> It can be refactored to account for changelog.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
