Re: Retaining uploaded job jars on Flink HA restarts on Kubernetes

2018-05-07 Thread Rohil Surana
Yes, I am aware that to restart the jobs Flink won't require the jars. But would have been awesome if it could have retained those. Thanks all for the help. Regards, - Rohil On Mon 7 May, 2018, 5:32 PM Sampath Bhat, wrote: > Hi Rohil > > You need not upload the jar again when job manager resta

Re: Retaining uploaded job jars on Flink HA restarts on Kubernetes

2018-05-07 Thread Sampath Bhat
Hi Rohil You need not upload the jar again when job manager restarts in an HA environment. Only the the jar stored in web.upload.dir will be deleted which is fine. The jars needed for the job manager to restart will be stored in high-availability.storageDir along with job graphs and job related st

Re: Retaining uploaded job jars on Flink HA restarts on Kubernetes

2018-05-07 Thread Rohil Surana
Ok. but why was this decision taken to automatically delete and not retain the jars, to me it makes sense to have the uploaded jars so user doesn't have to do it when JobManager restarts. Thanks. - Rohil On Mon, May 7, 2018 at 12:16 PM, Chesnay Schepler wrote: > The jar directory is automatical

Re: Retaining uploaded job jars on Flink HA restarts on Kubernetes

2018-05-06 Thread Chesnay Schepler
The jar directory is automatically deleted when a JobManager shuts down. In other words, there is no way to retain uploaded jars if a JobManager dies, and no way to point a JobManager to a pre-existing directory. On 07.05.2018 08:18, Chirag Dewan wrote: I think you are looking for *jobmanager

Re: Retaining uploaded job jars on Flink HA restarts on Kubernetes

2018-05-06 Thread Rohil Surana
Hey Chirag, I tried adding both the configs as per the documentation, and I can see the jars getting uploaded to the specified paths, but on JobManager restarts the JARS are actually *deleted* *from* the `jobmanager.web.upload.dir` path. Anything else that I am missing? Thanks. - Rohil On Mon,

Re: Retaining uploaded job jars on Flink HA restarts on Kubernetes

2018-05-06 Thread Chirag Dewan
I think you are looking for jobmanager.web.tmpdir along with upload.dirĀ  >From the documentation : - jobmanager.web.tmpdir: This configuration parameter allows defining the Flink web directory to be used by the web interface. The web interface will copy its static files into the dire

Retaining uploaded job jars on Flink HA restarts on Kubernetes

2018-05-05 Thread Rohil Surana
Hi, I have a very basic Flink HA setup on Kubernetes and wanted to retain job jars on JobManager Restarts. For HA I am using a Zookeeper and a NFS drive mounted on all pods (JobManager and TaskManagers), that is being used for checkpoints and have also set the `web.upload.dir: /data/flink-uploads