flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Flink Jira Bot (Jira)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-12047) State Processor API (previously named Savepoint Connector) to read / write / process savepoints
Date Thu, 27 May 2021 23:04:03 GMT

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

Flink Jira Bot updated FLINK-12047:
    Labels: stale-assigned  (was: )

I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community
manage its development. I see this issue is assigned but has not received an update in 14,
so it has been labeled "stale-assigned".
If you are still working on the issue, please remove the label and add a comment updating
the community on your progress.  If this issue is waiting on feedback, please consider this
a reminder to the committer/reviewer. Flink is a very active project, and so we appreciate
your patience.
If you are no longer working on the issue, please unassign yourself so someone else may work
on it. If the "warning_label" label is not removed in 7 days, the issue will be automatically

> State Processor API (previously named Savepoint Connector) to read / write / process
> -----------------------------------------------------------------------------------------------
>                 Key: FLINK-12047
>                 URL: https://issues.apache.org/jira/browse/FLINK-12047
>             Project: Flink
>          Issue Type: New Feature
>          Components: API / State Processor
>            Reporter: Tzu-Li (Gordon) Tai
>            Assignee: Seth Wiesman
>            Priority: Major
>              Labels: stale-assigned
> This JIRA tracks the ongoing efforts and discussions about a means to read / write /
process state in savepoints.
> There are already two known existing works (that was mentioned already in the mailing
lists) related to this:
> 1. Bravo [1]
> 2. https://github.com/sjwiesman/flink/tree/savepoint-connector
> Essentially, the two tools both provide a connector to read or write a Flink savepoint,
and allows to utilize Flink's processing APIs for querying / processing the state in the savepoint.
> We should try to converge the efforts on this, and have a savepoint connector like this
in Flink.
> With this connector, the high-level benefits users should be able to achieve with it
> 1. Create savepoints using existing data from other systems (i.e. bootstrapping a Flink
job's state with data in an external database).
> 2. Derive new state using existing state
> 3. Query state in savepoints, for example for debugging purposes
> 4. Migrate schema of state in savepoints offline, compared to the current more limited
approach of online migration on state access.
> 5. Change max parallelism of jobs, or any other kind of fixed configuration, such as
operator uids.
> [1] https://github.com/king/bravo

This message was sent by Atlassian Jira

View raw message