现象
driver端 一个成功广播变量，在exector端无法获取广播变量
例子
driver端 广播变量
import scala.collection.JavaConversions._
def getVehicleMileage(): util.Map[String, Double] = { // 注意返回类型
val vehicleMileage = new mutable.HashMap[String, Double]() // 注意生成的类型
val jedis =jedisPool.getResource
val vehicleslocation = jedis.hgetAll("vehicle_last_location".getBytes)
vehicleslocation.foreach(x => {
val mileage = VehicleLocationReportProto.VehicleLocationReport.parseFrom(x._2).getMileage / 1000
vehicleMileage += (new String(x._1) -> mileage)
})
jedis.close()
vehicleMileage
}
val bro = sc.broadcast(getVehicleMileage())
exector端 获取广播变量
val vMileage = bro.value // 此时获取的 为null
问题原因
getVehicleMileage 返回值和类型不统一
解决办法
val vehicleMileage = new mutable.HashMap[String, Double]()
改为
val vehicleMileage = new util.HashMap[String, Double]()
写在最后
为啥返回类型不一直。exector端无法获取。不知道深层次的原因。
后续查看
