[
https://issues.apache.org/jira/browse/FLINK-26002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-26002.
----------------------------------
Resolution: Fixed
merged commit 1cf276b into apache:master
> Add test coverage for native format job upgrades
> ------------------------------------------------
>
> Key: FLINK-26002
> URL: https://issues.apache.org/jira/browse/FLINK-26002
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing
> Affects Versions: 1.15.0
> Reporter: Anton Kalashnikov
> Assignee: Anton Kalashnikov
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> # Initialization of job with an operator with states.
> # Do native savepoint/canonical savepoint/aligned checkpoint
> ## Change job shape(new custom operator) and/or record types
> ## One job, with all possible network exchanges (forward, keyBy, rebalance,
> broadcast, random, rescale), followed by stateful operator.
> ## No need to modify state schema. Just validate in some way that after
> upgrade state is assigned to correct operators (so the state should be
> affecting result of the operators/functions)
> ## Some record type that would allow us to validate consistency of the
> computations
> ## Validating sink, checking for the consistency
> ## Arbitrary job upgrade. Add two new operators. A chained mapping operator
> and a another keyed proceeded by keyed exchange . Change record type from int
> to string, without changing the “logical” value of the record (for example
> change 1 → "1")
> ## Job upgrade w/o changing the graph record type: no need to test for that
> # Restore from savepoint/checkpoint
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
