I call env.execute(). What do you mean for "configure the logger?"
Timo Walther wrote > 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&lt;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. >>> -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/