Re: Flunk savepoin(checkpoint) load api or debug

2019-11-08 Thread Congxian Qiu
Hi You can create a test class, add a test method in the test class, and add your logic in the test method. you can ref to CheckpointMetadataLoadingTest#testLoadAndValidateSavepoint. Best, Congxian qq <471237...@qq.com> 于2019年11月8日周五 下午2:41写道: > Hi all, > >Thanks very much. I wants to deb

Re: Flunk savepoin(checkpoint) load api or debug

2019-11-07 Thread qq
Hi all, Thanks very much. I wants to debug checkpoint with code. Below is my code. Anyway I am sorry I doesn’t understand UT class. def demo(): Unit = { val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism(1) env.enableCheckpointing(1) val checkpointConf

Re: Flunk savepoin(checkpoint) load api or debug

2019-11-06 Thread Congxian Qiu
Hi, If you just want to debug, maybe you can do this in UT class in module flink-runtime :) so that you do not need to handle the dependency problem, and access problem. Best, Congxian Jark Wu 于2019年11月6日周三 下午3:39写道: > Btw, user questions should be asked in user@f.a.o or user-zh@f.a.o. The > d

Re: Flunk savepoin(checkpoint) load api or debug

2019-11-05 Thread Jark Wu
Btw, user questions should be asked in user@f.a.o or user-zh@f.a.o. The dev ML is mainly used to discuss development. Best, Jark On Wed, 6 Nov 2019 at 15:36, Jark Wu wrote: > Hi, > > Savepoint.load(env, path) is in state processor API library, you should > add the following dependency in your p

Re: Flunk savepoin(checkpoint) load api or debug

2019-11-05 Thread Jark Wu
Hi, Savepoint.load(env, path) is in state processor API library, you should add the following dependency in your project. org.apache.flink flink-state-processor-api_2.11 1.9.1 You can see the docuementation for more detailed instructions [1]. Best, Jark [1]: https://ci.apache.org/proj

Flunk savepoin(checkpoint) load api or debug

2019-11-05 Thread qq
Hi all, I want to load checkpoint or savepoint metadata on dev . in this case , I want to debug saved checkpoint metadata. And I knew flink provided a api which is Savepoint.load(env, path), but I can’t find it and can’t use it. Anyone who know about this ? Could you help me ? Thanks very muc