flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai (Jira)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state
Date Thu, 16 Jan 2020 09:48:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016765#comment-17016765
] 

Tzu-Li (Gordon) Tai commented on FLINK-14122:
---------------------------------------------

One reason I see with supporting this is that people who were previously using {{ListCheckpointed}}
(its still annotate as public evolving and not deprecated) have a way out using the state
processor API to migrate their state offline.

> Extend State Processor API to read ListCheckpointed operator state
> ------------------------------------------------------------------
>
>                 Key: FLINK-14122
>                 URL: https://issues.apache.org/jira/browse/FLINK-14122
>             Project: Flink
>          Issue Type: Sub-task
>          Components: API / DataStream
>    Affects Versions: 1.10.0
>            Reporter: Seth Wiesman
>            Priority: Major
>              Labels: usability
>             Fix For: 1.11.0
>
>
> The state processor api cannot  read operator state using the ListCheckpointed interface
because it requires access the JavaSerializer which is package private. Instead of making
that class public, we should offer a readListCheckpointed Method to easily read this state.



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

Mime
View raw message