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

Reply via email to