Hi Chiwan,
I’m not expert of Scala but It seems about closure cleaning problem. Scala
> App trait extends DelayedInit trait to initialize object. But Flink
> serialization stack doesn’t handle this special initialization. (It is just
> my opinion, not verified.)
>
I arrived at the same conclusion
Hi Andrea,
I’m not expert of Scala but It seems about closure cleaning problem. Scala App
trait extends DelayedInit trait to initialize object. But Flink serialization
stack doesn’t handle this special initialization. (It is just my opinion, not
verified.)
To run TFIDFNPE safely, you need to j
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
