I was long awaiting this feature! I can not help much with reviewing, but big +1 from my side :)
One thing that would be great for analyzing the state and possible smaller modifications, would be to hook this in with Flink SQL :) Especially if it could be done in a way that would work out of the box with minimal or no configuration required, like just opening SQL CLI with just maybe a pointer to savepoint id? Side question, are you aiming with this for 1.9 release? 1.10? Or you do not have a specific time frame? I’m asking since users are quite frequently asking for this and it would be good to know what to answer them. Piotrek > On 29 May 2019, at 17:51, Seth Wiesman <sjwies...@gmail.com> wrote: > > 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 to make breaking scheme changes or correct invalid > state > > We are looking forwards to your feedback! > > This is the FLIP: > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-43%3A+Savepoint+Connector > > Seth
