Accessed it: val CURRENT_EXECUTING = ClusterVariableEnumeration.CURRENT_EXECUTION.value.asInstanceOf[String]
On Mon, Dec 23, 2013 at 11:27 AM, Archit Thakur <[email protected]>wrote: > 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") > > and then in map function When I tried to access it it gave me NPE. Idea? > > Thanks and Regards, > Archit Thakur. >
