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