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/
