flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From subash basnet <yasub...@gmail.com>
Subject DataStreamUtils not working properly
Date Tue, 19 Jul 2016 08:48:02 GMT
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

Mime
View raw message