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 <[email protected]> wrote: > Caused by: java.io.NotSerializableException: > com.pws.sparkStreaming.collector.SavePowerTrackActivityStream -- Marcelo --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
