Hey Everyone!
Gordon and I have been discussing adding a savepoint connector to flink for
reading, writing and modifying savepoints.
This is useful for:
- Analyzing state for interesting patterns
- Troubleshooting or auditing jobs by checking for discrepancies in state
- Bootstrapping state for new applications
- Modifying savepoints such as:
- Changing max parallelism
- Making breaking schema changes
- Correcting invalid state
We are looking forward to your feedback!
This is the FLIP:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-42%3A+Savepoint+Connector<
https://cwiki.apache.org/confluence/display/FLINK/FLIP-41%3A+Unify+Keyed+State+Snapshot+Binary+Format+for+Savepoints>
.
--
Seth Wiesman
Locked
