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
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
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
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
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
