The easiest explanation is that there is nothing to print.
Since print statements within the select function don't appear in the
logs I assume
that the result of HTM.learn is empty.
Please check via the webUI or metrics whether any of these operations
actually return records.
On 29.08.2017 13:19, AndreaKinn wrote:
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<Double,Double>> result = HTM.learn(kafkaStream, new
Harness.AnomalyNetwork())
.select(new
InferenceSelectFunction<Harness.KafkaRecord,
Tuple2<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.
