Is the class mentioned in the exception below the parent class of the anonymous "Function" class you're creating?
If so, you may need to make it serializable. Or make your function a proper "standalone" class (either a nested static class or a top-level one). On Wed, May 11, 2016 at 3:55 PM, Andy Davidson <a...@santacruzintegration.com> wrote: > Caused by: java.io.NotSerializableException: > com.pws.sparkStreaming.collector.SavePowerTrackActivityStream -- Marcelo --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
