Re: Understanding iteration error message

2016-07-20 Thread Maximilian Michels
Hi, It's stating that you can't use a DataStream which was not part of the iteration. It works with `newCentroids` because it is part of the loop. The only way to get the centroids DataStream in, is to union/join it with the `newCentroids` stream. Cheers, Max On Wed, Jul 20, 2016 at 11:33 AM, s

Understanding iteration error message

2016-07-20 Thread subash basnet
Hello all, When I execute the below streaming code: DataStream *centroids* = newCentroidDataStream.map(new TupleCentroidConverter()); ConnectedIterativeStreams loop = *points*.iterate().withFeedbackType(Centroid.class); DataStream *newCentroids* = loop.flatMap(new SelectNearestCenter(10)).map(new