Re: Extracting Timestamp in MapFunction

Posted by Biplob Biswas on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Extracting-Timestamp-in-MapFunction-tp7240p7481.html

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