Have you tried making A extend Serializable?
On Thu, May 1, 2014 at 3:47 PM, SK <skrishna...@gmail.com> wrote: > Hi, > > I have the following code structure. I compiles ok, but at runtime it aborts > with the error: > Exception in thread "main" org.apache.spark.SparkException: Job aborted: > Task not serializable: java.io.NotSerializableException: > I am running in local (standalone) mode. > > trait A{ > def input(...): ... > def output(...) > def computeSim(...): ... { } > } -- Marcelo