Chesnay Schepler wrote
> 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.
>>
I'm losing my head in 6 hours...
To try to start flink job in webUI I tried to generate the jar of my flink
program using mvn clean package command.
I had to solve several problems about external libraries, then the command
worked but now in Eclipse everything is fucked. I have many errors something
like ClassNotFoundException. I tried everything but I'm not able to rewind
the program to the last functioning configuration. I'm desperate...
I'm not an expert of maven, what it does exactly and how can I cancel the
clean operation to go back to the previous config?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/datastream-print-doesn-t-works-tp15223p15237.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
