: Debug job execution from savepoint
Similarly, the AbstractOperatorRestoreTestBase shows how to start en embedded
cluster and submit a job from a savepoint.
see
* #restoreJob
* #createJobGraph
* MiniClusterResource
On 22.06.2018 13:53, Tzu-Li (Gordon) Tai wrote:
Hi,
The tests in Flink uses
* 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
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
Envoyé : jeudi 21 juin 2018 10:33:10
À : Haddadi Manuel
Cc : user@flink.apache.org
Objet : Re: Debug job execution from
De : Fabian Hueske
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
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 :
> Hi all,
>
>
> I
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
