Re: How to recover state from savepoint on embedded mode?

2019-11-29 Thread Biao Liu
if JM can read from the >> given path. no math which mode the job is running on. >> >> Best, >> Congxian >> >> >> Reo Lei 于2019年11月26日周二 下午12:18写道: >> >>> >>> >>> -- Forwarded message - >>> 发件人

Re: How to recover state from savepoint on embedded mode?

2019-11-29 Thread Dawid Wysakowicz
Best, > Congxian > > > Reo Lei mailto:leinuo...@gmail.com>> > 于2019年11月26日周二 下午12:18写道: > > > > -- Forwarded message - > 发件人: *Reo Lei* <mailto:leinuo...@gmail.com>> > Date: 2019年11月26日周二 上午9

Re: How to recover state from savepoint on embedded mode?

2019-11-28 Thread Arvid Heise
if JM can read from the > given path. no math which mode the job is running on. > > Best, > Congxian > > > Reo Lei 于2019年11月26日周二 下午12:18写道: > >> >> >> -- Forwarded message - >> 发件人: Reo Lei >> Date: 2019年11月26日周二 上午9:53 >> Sub

Re: How to recover state from savepoint on embedded mode?

2019-11-27 Thread Congxian Qiu
de, >> you cannot resume from savepoint now; if you refer to local standalone >> cluster, you could use `bin/flink run -s` to resume on a local cluster. >> >> >> >> Best >> >> Yun Tang >> >> >> >> *From: *Reo Lei >> *Dat

Fwd: How to recover state from savepoint on embedded mode?

2019-11-25 Thread Reo Lei
-- Forwarded message - 发件人: Reo Lei Date: 2019年11月26日周二 上午9:53 Subject: Re: How to recover state from savepoint on embedded mode? To: Yun Tang Hi Yun, Thanks for your reply. what I say the embedded mode is the whole flink cluster and job, include jobmanager, taskmanager

Re: How to recover state from savepoint on embedded mode?

2019-11-25 Thread Yun Tang
To: "user@flink.apache.org" Subject: How to recover state from savepoint on embedded mode? Hi, I have a job need running on embedded mode, but need to init some rule data from a database before start. So I used the State Processor API to construct my state data and save it to the local di

How to recover state from savepoint on embedded mode?

2019-11-25 Thread Reo Lei
Hi, I have a job need running on embedded mode, but need to init some rule data from a database before start. So I used the State Processor API to construct my state data and save it to the local disk. When I want to used this savepoint to recover my job, I found resume a job from a savepoint need