esh Patel
> Sent: Thursday, May 04, 2017 10:00 AM
> To: 'user@flink.apache.org'
> Subject: assignTimestampsAndWatermarks not working as expected
>
> Can anybody see what’s wrong with the following code? I am using Flink 1.2
> and have tried running it in Eclipse (loc
'
Subject: assignTimestampsAndWatermarks not working as expected
Can anybody see what's wrong with the following code? I am using Flink 1.2
and have tried running it in Eclipse (local mode) as well as on a 3 node
cluster and it's not behaving as expected.
The idea is to hav
Can anybody see what's wrong with the following code? I am using Flink 1.2
and have tried running it in Eclipse (local mode) as well as on a 3 node
cluster and it's not behaving as expected.
The idea is to have a custom source collect messages from a JMS topic (I
have a fake source for now tha
