RE: Problems with RollingSink

2016-11-29 Thread Diego Fustes Villadóniga
mail.com] Enviado el: martes, 29 de noviembre de 2016 15:52 Para: user@flink.apache.org Asunto: Re: Problems with RollingSink Hi Diego, If you want the data of all streams to be written to the same files, you can also union the streams before sending them to the sink. Best, Fabian 2016-1

Re: Problems with RollingSink

2016-11-29 Thread Fabian Hueske
t; streams somehow before sinking… maybe through Kafka? > > Kind Regards, > > Diego > > > > *De:* Kostas Kloudas [mailto:k.klou...@data-artisans.com > ] > *Enviado el:* lunes, 28 de noviembre de 2016 19:13 > *Para:* user@flink.apache.org > *Asunto:* Re: Problems with Rol

Re: Problems with RollingSink

2016-11-29 Thread Kostas Kloudas
o achieve this in a different manner by joining the > streams somehow before sinking… maybe through Kafka? > > Kind Regards, > > Diego > > >   <> > De: Kostas Kloudas [mailto:k.klou...@data-artisans.com] > Enviado el: lunes, 28 de noviembre de 2016

RE: Problems with RollingSink

2016-11-29 Thread Diego Fustes Villadóniga
this in a different manner by joining the streams somehow before sinking… maybe through Kafka? Kind Regards, Diego De: Kostas Kloudas [mailto:k.klou...@data-artisans.com] Enviado el: lunes, 28 de noviembre de 2016 19:13 Para: user@flink.apache.org Asunto: Re: Problems with RollingSink Hi

Re: Problems with RollingSink

2016-11-28 Thread Kostas Kloudas
Hi Diego, The message shows that two tasks are trying to touch concurrently the same file. This message is thrown upon recovery after a failure, or at the initialization of the job? Could you please check the logs for other exceptions before this? Can this be related to this issue? https://www.