I figured out what's wrong - there was a silly mistake on my side. There is
nothing wrong with the code here, but please do let me know if you see
anything wrong with my approach.
Thank you.
From: Jayesh Patel
Sent: Thursday, May 04, 2017 10:00 AM
To: 'user@flink.apache.org
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
