Hi, Did you check task manager and job manager logs for any problems?
Piotrek > On 5 Feb 2018, at 03:19, syed <ms110400...@vu.edu.pk> wrote: > > Hi > I am new to the flink world, and trying to understand. Currently, I am using > Flink 1.3.2 on a small cluster of 4 nodes, > I have configured checkpoint directory at HDFS, and run streaming word count > example with my own custom input file of 63M entries, > I enabled checkpoint every one second {/env.enableCheckpointing(1000)/} > > The problem I am facing is checkpoint is only triggered once after 1 second, > but no checkpoint afterwards, I run application for more than 5 minutes, but > checkpoint history shows only 1 checkpoint triggered and was successful. I > don't know why checkpoint not triggering after every second? > Please suggest me what is wrong? > Thanks in anticipation. > > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/