Re: ElasticSearch Checkpointing taking too much time

2018-09-11 Thread shashank734
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: ElasticSearch Checkpointing taking too much time

2018-09-11 Thread shashank734
Hi, vino, I have tried bot HDFS and filesystem and other checkpoints completed successfully so access is not the issue. For debug mode, I have to restart the app. I'll check and let you know thanks -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: ElasticSearch Checkpointing taking too much time

2018-09-11 Thread shashank734
Hi Hequn, Actually there are no error logs and to turn on debug mode I have to restart the app, Actually, I am using around 25-30 operators all others are completing successfully in less time only elastic search sink is taking too much time. I am using around 6 Elastic search sinks all are takin

Re: ElasticSearch Checkpointing taking too much time

2018-09-11 Thread vino yang
Hi shashank, Hequn's solution is right. In addition, what type of statebackend you use, please make sure that JM/TM can access related systems (such as HDFS). If you still can't locate the problem, you can set the log level to DEBUG and share your log information. Thanks, vino. Hequn Cheng 于201

Re: ElasticSearch Checkpointing taking too much time

2018-09-11 Thread Hequn Cheng
Hi shashank, The parallelism won't be the problem. Did the checkpoint succeed finally? I think it may be that the data processing is blocked so that the checkpoint can not been successful. You can check if there are any error logs in the TaskManager or jstack the taskmanager to see what's wrong th

Re: ElasticSearch Checkpointing taking too much time

2018-09-11 Thread shashank734
Update: I am using parallelism 1 on this... is this issue? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

ElasticSearch Checkpointing taking too much time

2018-09-11 Thread shashank734
I am using flink 1.5.3, In this i am using elastic search sink. In this checkpoints and savepoints are failing, I have already given 50 minutes timeouts. After looking into details only elastic search sink checkpoints are taking time 30-35 mins. But state size and buffer size is 0 in that. Don't kn