Re: Flink stops deploying jobs on normal iteration

2016-07-07 Thread Nguyen Xuan Truong
broadcast set > inside the iteration? If I understand correctly this is a dataset with a > single value, right? Could you maybe compute it with an aggregator instead? > > -Vasia. > > On 5 July 2016 at 21:48, Nguyen Xuan Truong wrote: > >> Hi Vasia, >> >> T

Re: Flink stops deploying jobs on normal iteration

2016-07-05 Thread Nguyen Xuan Truong
hing > intermediate results yet. This has been a quite often requested feature > lately, so maybe it will be added soon :) > Until then, I suggest you try implementing your logic using iterate or > iterateDelta. > > Cheers, > -Vasia. > > On 5 July 2016 at 17:11, Nguyen Xua

Flink stops deploying jobs on normal iteration

2016-07-05 Thread Nguyen Xuan Truong
Hi, I have a Flink program which is similar to Kmeans algorithm. I use normal iteration(for loop) because Flink iteration does not allow to compute the intermediate results(in this case the topDistance) within one iteration. The problem is that my program only runs when maxIteration is small. When