Re: DataStream of Future

2016-09-16 Thread Guowei Ma
Hi,Albert I think that the futures may be lost if the machine is down for some reasons. So simply using the futures may not be acceptable in production. I hope this is helpful. Thanks > 在 2016年9月16日,下午3:01,alghimo 写道: > > Hi Timo, > > Thank you for the fast reply :) I will check and follow th

Re: DataStream of Future

2016-09-16 Thread alghimo
Hi Timo, Thank you for the fast reply :) I will check and follow the discussion, it would be really cool to be able to have that feature. As for the updates, there I'm using Futures which update accumulators on success / failure, and everything seems to be working fine, I tested both in local mod

Re: DataStream of Future

2016-09-16 Thread Timo Walther
Hi Albert, you cannot use Futures between operators as objects are seralialized and possibly sent through the cluster immediatly. Right now there is no straight forward way in Flink to do async calls. However, there is a discussion going on which you might wanna join [1]. As far as I know, th