I think when you do a ssc.stop it will stop your entire application and by
update a transformation function you mean modifying the driver program?
In that case even if you checkpoint your application, it won't be able to
recover from its previous state.
A simpler approach would be to add certain
Hi all,
Has anyone tried to add Scripting capabilities to spark streaming using groovy?
I would like to stop the streaming context, update a transformation function
written in groovy( for example to manipulate json ), restart the streaming
context and obtain a new behavior without re-submit the
