Re: Flink CLI properties with HA

2018-07-18 Thread Sampath Bhat
g item *high-availability.storageDir* is storage >>>> (Job graph, checkpoint and so on). Actually, the real data is stored under >>>> this path which used to recover purpose, zookeeper just store a state >>>> handle. >>>> >>>> --- >>>>

Re: Flink CLI properties with HA

2018-07-17 Thread Till Rohrmann
urpose, zookeeper just store a state >>> handle. >>> >>> --- >>> Thanks. >>> vino. >>> >>> >>> 2018-07-16 15:28 GMT+08:00 Sampath Bhat : >>> >>>> >>>> -- Forwarded message ---

Re: Flink CLI properties with HA

2018-07-17 Thread vino yang
>> 2018-07-16 15:28 GMT+08:00 Sampath Bhat : >> >>> >>> -- Forwarded message -- >>> From: Sampath Bhat >>> Date: Fri, Jul 13, 2018 at 3:18 PM >>> Subject: Flink CLI properties with HA >>> To: user >>>

Re: Flink CLI properties with HA

2018-07-17 Thread Sampath Bhat
> >> >> -- Forwarded message -- >> From: Sampath Bhat >> Date: Fri, Jul 13, 2018 at 3:18 PM >> Subject: Flink CLI properties with HA >> To: user >> >> >> Hello >> >> When HA is enabled in the flink cluster an

Re: Flink CLI properties with HA

2018-07-16 Thread vino yang
t; Date: Fri, Jul 13, 2018 at 3:18 PM > Subject: Flink CLI properties with HA > To: user > > > Hello > > When HA is enabled in the flink cluster and if I've to submit job via > flink CLI then in the flink-conf.yaml of flink CLI should contain this > proper

Fwd: Flink CLI properties with HA

2018-07-16 Thread Sampath Bhat
-- Forwarded message -- From: Sampath Bhat Date: Fri, Jul 13, 2018 at 3:18 PM Subject: Flink CLI properties with HA To: user Hello When HA is enabled in the flink cluster and if I've to submit job via flink CLI then in the flink-conf.yaml of flink CLI should contain

Flink CLI properties with HA

2018-07-13 Thread Sampath Bhat
Hello When HA is enabled in the flink cluster and if I've to submit job via flink CLI then in the flink-conf.yaml of flink CLI should contain this properties - high-availability: zookeeper high-availability.cluster-id: flink high-availability.zookeeper.path.root: flink high-availability.storageDir