1. For what reasons is using Spark the above ports? What internal component
is triggering them? -Akka(guessing from the error log) is used to schedule
tasks and to notify executors - the ports used are random by default
2. How I can get rid of these errors? - Probably the ports are not open on
you
Hello!
I received the following errors in the workerLog.log files:
ERROR EndpointWriter: AssociationError [akka.tcp://sparkWorker@stream4:33660]
-> [akka.tcp://sparkExecutor@stream4:47929]: Error [Association failed with
[akka.tcp://sparkExecutor@stream4:47929]] [
akka.remote.EndpointAssociationE