flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: datastream.print() doesn't works
Date Tue, 29 Aug 2017 15:01:37 GMT
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&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.
>>


Mime
View raw message