flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yassine MARZOUGUI <y.marzou...@mindlytix.com>
Subject Re: Windows emit results at the end of the stream
Date Fri, 24 Mar 2017 10:23:56 GMT
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.


2017-03-23 13:16 GMT+01:00 Sonex <alfredjenssen@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.

View raw message