In the worker logs i can see,
14/04/16 01:02:47 ERROR EndpointWriter: AssociationError
[akka.tcp://sparkWorker@xx:10548] ->
[akka.tcp://sparkExecutor@xx:16041]: Error [Association failed with
[akka.tcp://sparkExecutor@xx:16041]] [
akka.remote.EndpointAssociationException: Association f
I am getting a java.net.SocketException: Network is unreachable whenever i
do a count on one of my tables.
If i just do a take(1), i see the task status as killed on the master UI
but i get back the results.
My driver runs on my local system which is accessible over the public
internet and connects