Re: Incremental updates

2016-05-27 Thread Malgorzata Kudelska
26 May 2016 at 15:50 Malgorzata Kudelska wrote: > Hi, > So is there any possibility to utilize an extra node that joins the > cluster or will it remain idle? > What if I use a custom key function that matches the key variable to a > number of keys bigger than the initial number of nodes (

Re: Incremental updates

2016-05-26 Thread Malgorzata Kudelska
and the state are > correctly matched. > > 3. Also answered by the above, I hope at least :-) > > 4. This does currently not work but the ongoing work in this is tracked by > https://issues.apache.org/jira/browse/FLINK-3755. > > Cheers, > Aljoscha > > On Wed, 25 May

Re: Incremental updates

2016-05-25 Thread Malgorzata Kudelska
ssary changes: https://docs.google.com/document/d/1G1OS1z3xEBOrYD4wSu-LuBCyPUWyFd9l3T9WyssQ63w/edit?usp=sharing Cheers, Aljoscha On Wed, 25 May 2016 at 13:32 Malgorzata Kudelska wrote: > Hi, > Thanks for your reply. > > Is Flink able to detect that an additional server joined and rebalance

Re: Incremental updates

2016-05-25 Thread Malgorzata Kudelska
>> +34 902 286 386 - +34 607 18 28 06 >> Parque Tecnológico de Asturias · Parcela 30 >> E33428 Llanera · Asturias [Spain] >> <http://www.treelogic.com>www.treelogic.com >> __ >> >> >> - Mensaje original - >> De: "M

Incremental updates

2016-05-24 Thread Malgorzata Kudelska
Hi, I have the following question. Does Flink support incremental updates? In particular, I have a custom StateValue object and during the checkpoints I would like to save only the fields that changed since the previous checkpoint. Is that possible? Regards, Gosia