Hi, The tests in Flink uses a `AbstractStreamOperatorTestHarness` that allows wrapping an operator, input elements into the operator, getting the outputs, and also snapshotting / restoring operator state. I’m not sure of your specific case, but in general that test harness utility can be used to test the operator’s output and state update logic for a given set of input records.
Cheers, Gordon On 22 June 2018 at 11:23:28 AM, Haddadi Manuel (manuel.hadd...@gfi.fr) wrote: Hi Fabian, thanks for your response. Here is the Jira issue : https://issues.apache.org/jira/browse/FLINK-9644 Would you have any devlopper tips on how testing my intializeState methods to validate that my savepoints are corrects ? Thank you again. Regards, Manuel De : Fabian Hueske <fhue...@gmail.com> Envoyé : jeudi 21 juin 2018 10:33:10 À : Haddadi Manuel Cc : user@flink.apache.org Objet : Re: Debug job execution from savepoint Hi Manuel, I had a look and couldn't find a way to do it. However, this sounds like a very useful feature to me. Would you mind creating a Jira issue [1] for that? Thanks, Fabian [1] https://issues.apache.org/jira/projects/FLINK 2018-06-18 16:23 GMT+02:00 Haddadi Manuel <manuel.hadd...@gfi.fr>: Hi all, I would like to test my checkpointing implementation doing a step-by-step debugging under an IDE. Is there a way to restore a job from a local savepoint in a local stream environnement, like a command "flink run -s :savepontpath" would do ? Thanks, Manuel
