Hi Max, Here is the code for Timestamp assigner and watermark generation. PFA
Regards, Vinay Patil On Thu, Aug 25, 2016 at 7:39 AM, Maximilian Michels [via Apache Flink User Mailing List archive.] <ml-node+s2336050n8685...@n4.nabble.com> wrote: > I'm assuming there is something wrong with your Watermark/Timestamp > assigner. Could you share some of the code? > > On Wed, Aug 24, 2016 at 9:54 PM, vinay patil <[hidden email] > <http:///user/SendEmail.jtp?type=node&node=8685&i=0>> wrote: > > > Hi, > > > > Just an update, the window is not getting triggered when I change the > > parallelism to more than 1. > > > > Can you please explain why this is happening ? > > > > Regards, > > Vinay Patil > > > > On Wed, Aug 24, 2016 at 9:55 AM, vinay patil [via Apache Flink User > Mailing > > List archive.] <[hidden email]> wrote: > >> > >> Hi Max, > >> > >> I tried writing to local file as well, its giving me the same issue, I > >> have attached the logs and dummy pipeline code.logs.txtdummy_pipeline.txt > > >> > >> ________________________________ > >> If you reply to this email, your message will be added to the > discussion > >> below: > >> > >> http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/Dealing-with-Multiple-sinks-in-Flink-tp8643p8664.html > >> To start a new topic under Apache Flink User Mailing List archive., > email > >> [hidden email] > >> To unsubscribe from Apache Flink User Mailing List archive., click > here. > >> NAML > > > > > > > > ________________________________ > > View this message in context: Re: Dealing with Multiple sinks in Flink > > > > Sent from the Apache Flink User Mailing List archive. mailing list > archive > > at Nabble.com. > > > ------------------------------ > If you reply to this email, your message will be added to the discussion > below: > http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/Dealing-with-Multiple-sinks-in-Flink-tp8643p8685.html > To start a new topic under Apache Flink User Mailing List archive., email > ml-node+s2336050n1...@n4.nabble.com > To unsubscribe from Apache Flink User Mailing List archive., click here > <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=1&code=dmluYXkxOC5wYXRpbEBnbWFpbC5jb218MXwxODExMDE2NjAx> > . > NAML > <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> > MyTimestampExtractor.java (4K) <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/attachment/8692/0/MyTimestampExtractor.java> -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dealing-with-Multiple-sinks-in-Flink-tp8643p8692.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
