then click the
run button again.
Let me google about the savepoint.
Thanks,
Lei Wang
wangl...@geekplus.com.cn
From: Stephan Ewen
Date: 2019-06-25 20:36
To: user
Subject: Re: Unable to restore state value after job failed using
RocksDBStateBackend
If you manually cancel and restart the job
20:36
To: user
Subject: Re: Unable to restore state value after job failed using
RocksDBStateBackend
If you manually cancel and restart the job, state is only carried forward if
you use a savepoint.
Can you check if that is what you are doing?
On Tue, Jun 25, 2019 at 2:21 PM Simon Su wrote:
Hi
If you manually cancel and restart the job, state is only carried forward
if you use a savepoint.
Can you check if that is what you are doing?
On Tue, Jun 25, 2019 at 2:21 PM Simon Su wrote:
>
> Hi wanglei
>
> Can you post how you restart the job ?
>
> Thanks,
> Simon
> On 06/25/2019 20:11，wang
public class StateProcessTest extends KeyedProcessFunction, String> {
private transient ValueState> state;
public void processElement(Tuple2 value, Context ctx,
Collector out) throws Exception {
Tuple2 stateValue = state.value();
if(stateValue == null){
