Re: Restoring from an external checkpoint / savepoint with a local stream environment

2017-02-03 Thread Kathleen Sharp
Thanks a lot for the detailed answer. From reading the code i suspected something would be possible, but this would have taken me a while to figure out. On Fri, Feb 3, 2017 at 2:08 PM, Ufuk Celebi wrote: > Hey Kathleen, > > this is not supported "natively" in the APIs but the following is > possi

Re: Restoring from an external checkpoint / savepoint with a local stream environment

2017-02-03 Thread Ufuk Celebi
Hey Kathleen, this is not supported "natively" in the APIs but the following is possible to work around it: int jobManagerPort = 6123; int numTaskSlots = 8; String savepointPath = "/Users/uce/Desktop/savepoint-xAsd"; Configuration config = new Configuration(); config.setInteger(ConfigConstants.J

Restoring from an external checkpoint / savepoint with a local stream environment

2017-02-03 Thread Kathleen Sharp
Hi, is it possible to restore from an external checkpoint / savepoint while using a local stream environment? I ask because I want to play around with some concepts from within my IDE, without building a jar and deploying my job. Thanks, Kat -- _