[jira] [Created] (FLINK-25465) Correct the logic to materizate on wrapped changelog state

["Yun Tang (Jira)" <ji...@apache.org>]

Yun Tang created FLINK-25465:
--------------------------------

             Summary: Correct the logic to materizate on wrapped changelog state
                 Key: FLINK-25465
                 URL: https://issues.apache.org/jira/browse/FLINK-25465
             Project: Flink
          Issue Type: Bug
          Components: Runtime / State Backends
            Reporter: Yun Tang
            Assignee: Yun Tang
             Fix For: 1.15.0


{{ChangelogKeyedStateBackend#keyValueStatesByName}} would store wrapped state, such as TTL state or latency tracking state. It will throw exception on initMaterialization if wrapped:


{code:java}
for (InternalKvState<K, ?, ?> changelogState : keyValueStatesByName.values()) {
                checkState(changelogState instanceof ChangelogState);
                ((ChangelogState) changelogState).resetWritingMetaFlag();
}
{code}




--
This message was sent by Atlassian Jira
(v8.20.1#820001)