Re: Flink not restoring from checkpoint when job manager fails even with HA through zookeeper

2020-06-06 Thread Vijay Bhaskar
Job is "FAILED" state and hence Flink HA Removed the job graph from zookeeper along with the state. One thing is we can't completely rely on Flink HA for state restoring. It will only until Job hasn't FAILED If you want to recover Job even after Failure, you should do the following: a) Use the

Re: [VOTE] Accept Stateful Functions into Apache Flink

2019-10-31 Thread Vijay Bhaskar
+1 from me Regards Bhaskar On Thu, Oct 31, 2019 at 11:42 AM Gyula Fóra wrote: > +1 from me, this is a great addition to Flink! > > Gyula > > On Thu, Oct 31, 2019, 03:52 Yun Gao wrote: > > > +1 (non-binding) > > Very thanks for bringing this to the community! > > > > > >

Re: [ANNOUNCE] Becket Qin joins the Flink PMC

2019-10-29 Thread Vijay Bhaskar
Congratulations Becket Regards Bhaskar On Tue, Oct 29, 2019 at 1:53 PM Danny Chan wrote: > Congratulations :) > > Best, > Danny Chan > 在 2019年10月29日 +0800 PM4:14,dev@flink.apache.org,写道: > > > > Congratulations :) >

Re: Connection leak with flink elastic Sink

2018-12-13 Thread Vijay Bhaskar
13 December 2018 at 5:59:34 PM, Chesnay Schepler (ches...@apache.org) > wrote: > > Specifically which connector are you using, and which Flink version? > > On 12.12.2018 13:31, Vijay Bhaskar wrote: > > Hi > > We are using flink elastic sink which streams at the rate of 1000

Connection leak with flink elastic Sink

2018-12-12 Thread Vijay Bhaskar
Hi We are using flink elastic sink which streams at the rate of 1000 events/sec, as described in https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/elasticsearch.html . We are observing connection leak of elastic connections. After few minutes all the open connections are