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

Posted to issues@flink.apache.org by "Jiayi Liao (Jira)" <ji...@apache.org> on 2019/09/19 09:47:00 UTC

[jira] [Commented] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

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

Jiayi Liao commented on FLINK-14122:
------------------------------------

[~sjwiesman] Hi I'm also paying attention to this module. 

About this issue, I don't fully understand why operator state reading is related to the ListCheckpointed interface? And readListCheckpointed method, what's the difference between readListState and it?

> 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
>
> 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)