Have you called collect() / count() on the RDD following flatMap() ? Cheers
On Tue, Jul 21, 2015 at 8:47 AM, <[email protected]> wrote: > > 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. >
