چرا در accumulator ارور type mismatch رو دریافت می کنم؟

[milad_molaee]

Up

0

Down

::

 

این ارور زیر دریافت میشه

 

محیط دیتابریک هستم ، ورژن اسپارک 2.4.3 و ورژن اسکالا هم 2.11 هست

 

import org.apache.spark.broadcast.Broadcast
import org.apache.spark.{Accumulator,SparkContext}
import org.apache.spark.util.AccumulatorV2
import org.apache.spark.mllib.linalg.Vector
import breeze.linalg.DenseVector
import breeze.linalg.{DenseVector=>BDV}
import breeze.linalg.Vector
import breeze.linalg.functions.euclideanDistance
import breeze.linalg._
import org.apache.log4j.{Level,Logger}
import org.apache.spark.rdd.RDD

import scala.util.Random
import math._
import scala.collection.mutable.ArrayBuffer
import org.apache.spark.mllib.clustering.KMeans
import org.apache.spark.mllib.clustering.BisectingKMeans

import vegas._
import vegas.render.WindowRenderer._

object VectorAccumulatorParam extendsAccumulatorV2[BDV[Double],BDV[Double]]{
def zero(v:BDV[Double]):BDV[Double]=v
def addInPlace(v1:BDV[Double],v2:BDV[Double]):BDV[Double]= v1 += v2
}

**//The following line gives the type error**
val errors=SC.sc.accumulator(BDV.zeros[Double](numParticles))(VectorAccumulatorParam)

• این موضوع 2 سال، 10 ماه پیش توسط ابوالفضل محمدی جو اصلاح شده است.
• این موضوع 1 سال، 10 ماه پیش توسط ابوالفضل محمدی جو اصلاح شده است.

[نویسنده]

نوشته‌ها