Hello all, Can someone help me to solve the following fundamental problem?
I have a JavaRDD and as a flatMap method, I call a new instance of a class which implements FlatMapFunction. This class has a constructor method and a call method. In constructor method, I set the values for "List" variables which I need them in call method. In local run, there is no problem and it works correctly, but when I run it on cluster (using YARN) it doesn't know them and the variables are null. (I get Null pointer exception) Any solution, idea or hint will be really appreciated, All the best, Soheila
