Hi Sonex,
I assume the elements in your file have a timestamp associated which is
parsed in the first map function, right? Now my question would be: What is
the range of this timestamp value? In your program you've defined a time
window of 1 hour. If the timestamps lie all in a window of 1 hour, then you
won't see the triggering of the windows before the complete file has been
read.
Cheers,
Till
On Fri, Mar 24, 2017 at 11:23 AM, Yassine MARZOUGUI <
y.marzou...@mindlytix.com> wrote:
> 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-maili
>> ng-list-archive.2336050.n4.nabble.com/Windows-emit-result
>> s-at-the-end-of-the-stream-tp12337p12356.html
>> Sent from the Apache Flink User Mailing List archive. mailing list
>> archive at Nabble.com.
>>
>
>
