flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrea Sella <andrea.se...@radicalbit.io>
Subject Unexpected behavior with Scala App trait.
Date Mon, 18 Jan 2016 15:08:46 GMT
Hi,

I was implementing TF-IDF example of flink-training when I faced a problem
with NPE during the deploy of my Job.

Source code: https://github.com/alkagin/flink-tfidf-example

I used 0.10.1 version and started in local mode.
During the deploy of TFIDFNPE Job, which it extends App, Flink throws
NullPointerException on both flatMap functions.
If I include the tokenize function into the closures of flatMap functions,
the Job works fine; see example TFIDFApp.
To avoid this unexpected behavior I don't have use Scala App trait, see
TFIDF, but why?


Thanks,
Andrea

Mime
View raw message