spark广播变量 无法在exector端获取

现象

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端无法获取。不知道深层次的原因。
后续查看