Hi Sonex,
I don't known well Scala as I know Java, but I guess it should be correct
if no error is raised.
The behaviour you described seems wierd to me and should not happen. I'm
unfortunately unable to identify an apparent cause, maybe someone in the
mailing list can shed a light on that.
Best,
Yassine
2017-03-23 13:16 GMT+01:00 Sonex <alfredjens...@gmail.com>:
> Thank you for your response Yassine,
>
> I forgot to mention that I use the Scala API. In Scala the equivalent code
> is:
>
> val inputFormat = new TextInputFormat(new Path("file/to/read.txt"))
> env.readFile(inputFormat,"file/to/read.txt",
> FileProcessingMode.PROCESS_CONTINUOUSLY,10000L)
>
> Am I correct?
>
> But I noticed a weird behavior now. Sometimes, it never starts to process
> the elements of the file and sometimes it stops at the middle of the file
> without processing the rest of it. Why does that happen?
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Windows-emit-
> results-at-the-end-of-the-stream-tp12337p12356.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
