Hi i am using spark 1.3.1 and i am trying to submit spark job to the rest url of spark ( spark:<host-name>:6066 using standalone cluster of spark with deploy mode as cluster . Both driver and application and getting submitted after doing their work (output created) both end up with killed status. In the worker logs i am seeing this error
ERROR EndpointWriter: AssociationError [akka.tcp://sparkWorker@Precision-T3610:53508] <- [akka.tcp://sparkExecutor@Precision-T3610:54047]: Error [Shut down address: akka.tcp://sparkExecutor@Precision-T3610:54047] [ akka.remote.ShutDownAssociation: Shut down address: akka.tcp://sparkExecutor@Precision-T3610:54047 Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down. ] Am i missing some config ? Can some one please help . Thanks in advance -- Regards Pavan Kumar Kolamuri
