Hello all, I am trying to convert datastream to collection, but it's shows blank result. There is a stream of data which can be viewed on the console on print(), but the collection of the same stream shows empty after conversion. Below is the code:
DataStream<Centroid> centroids = newCentroidDataStream.map(new TupleCentroidConverter()); centroids.print(); Iterator<Centroid> iter = DataStreamUtils.collect(centroids); Collection<Centroid> testCentroids = Lists.newArrayList(iter); for(Centroid c: testCentroids){ System.out.println(c); } The above *centroids.print()* gives the following output in console: Mon Jul 18 21:29:01 CEST 2016 119.3701 119.4 119.3701 119.38 27400.0 Mon Jul 18 21:23:00 CEST 2016 119.3463 119.37 119.315 119.37 48200.0 Mon Jul 18 21:27:59 CEST 2016 119.3401 119.3401 119.26 119.265 50300.0 Mon Jul 18 21:36:00 CEST 2016 119.48 119.505 119.47 119.4741 37400.0 Mon Jul 18 21:33:00 CEST 2016 119.535 119.54 119.445 119.455 152900.0 But the next *System.out.println(c) *within the for loop prints nothing. What could be the problem. My maven has following configuration for dataStreamUtils: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-contrib_2.10</artifactId> <version>${flink.version}</version> </dependency> Best Regards, Subash Basnet