Don't forget to call env.execute() at the end and make sure you have
configured your logger correctly.
Regards,
Timo
Am 29.08.17 um 14:59 schrieb Chesnay Schepler:
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.
