Hi,
I am getting NPE while I access broadcast variable.
I created an object:
object ClusterVariableEnumeration {
var CURRENT_EXECUTION: org.apache.spark.broadcast.Broadcast[Any] = null.asInstanceOf[org.apache.spark.broadcast.Broadcast[Any]];
}
and then after creating SparkContext, I did ClusterVariableEnumeration.CURRENT_EXECUTION = sc.broadcast("value")