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.
- Accumulator value 0 in driver dlmarion
- Re: Accumulator value 0 in driver Ted Yu
- Re: Accumulator value 0 in driver dlmarion
- Re: Accumulator value 0 in driver dlmarion