Just to add up, if you use LocalStreamEnvironment, you can pass a configuration and you can set "execution.savepoint.path" to point to your savepoint.
Best, Arvid On Wed, Nov 27, 2019 at 1:00 PM Congxian Qiu <qcx978132...@gmail.com> wrote: > Hi, > > You can recovery from checkpoint/savepoint if JM&TM can read from the > given path. no math which mode the job is running on. > > Best, > Congxian > > > Reo Lei <leinuo...@gmail.com> 于2019年11月26日周二 下午12:18写道： > >> >> >> ---------- Forwarded message --------- >> 发件人： Reo Lei <leinuo...@gmail.com> >> Date: 2019年11月26日周二 上午9:53 >> Subject: Re: How to recover state from savepoint on embedded mode? >> To: Yun Tang <myas...@live.com> >> >> >> Hi Yun, >> Thanks for your reply. what I say the embedded mode is the whole flink >> cluster and job, include jobmanager, taskmanager and the job application >> itself, running within a local JVM progress, which is use the " >> LocalStreamEnvironment" within the job. And the start command look like >> this: "java -Xmx512M -XX:... -Dlog.file=... -cp flink-job.jar >> com.a.b.c.MyJob > /dev/null &" >> >> why I am not use the standalnoe mode to run the job is because the >> running env haven't zookeeper, and would not install the zookeeper. So I >> need to depend on the embedded mode to run my job. >> >> BR, >> Reo >> >> Yun Tang <myas...@live.com> 于2019年11月26日周二 上午2:38写道： >> >>> What is the embedded mode mean here? If you refer to SQL embedded mode, >>> 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 <leinuo...@gmail.com> >>> *Date: *Tuesday, November 26, 2019 at 12:37 AM >>> *To: *"user@flink.apache.org" <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 disk. When I want to used >>> this savepoint to recover my job, I found resume a job from a savepoint >>> need to use the command `bin/flink run -s :savepointPath *[*:runArgs]` >>> to submit a job to flink cluster. That is mean the job is run on remote >>> mode, not embedded mode. >>> >>> >>> >>> And I was wondering why I can't resume a job from a savepoint on >>> embedded mode. If that is possible, what should I do? >>> >>> BTW, if we can not resume a job from a savepoint on embedded mode, how >>> to know the savepoint is constructed correctly in develop environment and >>> use idea to debug it? >>> >>> >>> >>> BR, >>> >>> Reo >>> >>> >>> >>
