Re: Window not emitting output after upgrade to Flink 1.1.1

Hi Kostas, Yes, that's the case. I will revert back to 1.0.3 until the bug is fixed. Thank you. Best, Yassine On Fri, Aug 12, 2016 at 10:34 AM, Kostas Kloudas < k.klou...@data-artisans.com> wrote: > Hi Yassine, > > Are you reading from a file and use ingestion time? > If yes, then the problem c

Re: Window not emitting output after upgrade to Flink 1.1.1

Hi Yassine, Are you reading from a file and use ingestion time? If yes, then the problem can be related to this: https://issues.apache.org/jira/browse/FLINK-4329 Is this the case? Best, Kostas > On Aug 12, 2016, at 10:30 AM, Yassine Marzougui

Window not emitting output after upgrade to Flink 1.1.1

Hi all, The following code works under Flink 1.0.3, but under 1.1.1 it just switches to FINISHED and doesn't output any result. stream.map(new RichMapFunction() { private ObjectMapper objectMapper; @Override public void open(Configuration parameters) { object