datastream.print() doesn't works

[AndreaKinn]

Hi, 
I have a simple datastream of a Tuple2. Unfortunately when I call the
print() method. No one output is showed although no errors or exceptions are
raised.
I want to highlight that I have also other data streams which are correctly
printed.

This is the stream:

/DataStream<Tuple2&lt;Double,Double>> result = HTM.learn(kafkaStream, new
Harness.AnomalyNetwork())
                                .select(new 
InferenceSelectFunction<Harness.KafkaRecord,
Tuple2&lt;Double, Double>>() {
                                          @Override
                                          public Tuple2<Double,Double>
select(Tuple2<Harness.KafkaRecord, NetworkInference> inference) throws
Exception {
                                          return new Tuple2<Double, 
Double>(3.14444,
inference.f1.getAnomalyScore());
                                         }
});/

I'm quite sure the problem isn't in the particular function described above
because effectively in inner functions of getAnomalyScore for example the
return value exists. 

Anyway I'm not able to find the problem which doesn't allow to print the
stream so I thought to write here to discover if there are typical situation
where streams are not printed. How can I verify and debug the problem? Some
hints about it ? I really tried everything, also tried to print something in
the function select() for example, with no results



--
View this message in context: 
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/datastream-print-doesn-t-works-tp15223.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at 
Nabble.com.