Quick start guide

Hi, I was following the quick start guide on official documents , and I came cross a line that caused a bit confusion. $ tail -f log/flink-*-jobmanager-*.out It is said the wordcount program would

Re: termination of stream#iterate on finite streams

Hi Xingcan! if a _finite_ stream would, at the end, emit a special, trailing "End-Of-Stream Message" that floats downward the operator stream, wouldn't this enable us to deterministically end the iteration without needing a timeout? Having an arbitrary timeout that must be longer than any

Re: set state.checkpoint.dir to execution environment

Hi Jose, It seems that you enable the externalized checkpoints in your streaming job. If enabling externalized checkpoints is what you really want to, 'state.checkpoints.dir' must be set in flink-conf.yaml. For your second question, yes, the only way is to modify the flink-conf.yaml. See the