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
