Hi Aljoscha, I went to the Flink hackathon by Buzzwords yesterday where Fabian and Robert helped me with this issue. Apparently I was assuming that the file would be handled in a single thread but I was using parallelsourcefunction and it was creating 4 different threads and thus reading the same values 4 times. I changed it to source function and then changed the parallelism of the map operator to do what I wanted to do.
Thanks a lot for replying. :) Regards Biplob -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Extracting-Timestamp-in-MapFunction-tp7240p7481.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
