I am using Accumulators in a JavaRDD<LabeledPoint>.flatMap() method. I have 
logged the localValue() of the Accumulator object and their values are 
non-zero. In the driver, after the .flatMap() method returns, the calling 
value() on the Accumulator yields 0. I am running 1.4.0 in yarn-client mode. 
Any pointers would be appreciated. 

Reply via email to