Пытается десериализовать сериализованный ActorRef без системы ActorSystem - Spark/Akka/Scala

Question

EDIT: Исключение, связанное с сериализацией/десериализацией Акка Актер остается после того, как forEach подтверждается, что выполняется. Я изучаю Акку и сталкиваюсь с этой проблемой сериализации, я совершенно новичок в Akka и считаю довольно сложно понять, как лучше всего подойти к решению.

У меня есть класс, в котором создан actorSystem и актер, этот класс вызывает метод в другом классе, я хотел бы использовать моего актера в этом другом классе. До сих пор я пытался:

Class a: 
-create actor 
-classB.methodX(actor) 

Class b: 
-methodX(actorRef) 
--actorRef! message 

настоящее сообщение из класса б не присылают в то время как те, класс А сделать, это заставляет меня думать, что я либо нужно создать экземпляр нового актера с ActorRef, что я Переходим, или это совершенно неправильно.

Я понимаю, что система должна присутствовать на всех узлах, но я не уверен, как это сделать.

Edit: Код Отрывки:

ClassA: 
    private val system = ActorSystem("System") 
    private val metricActor= system.actorOf(Props(new MetricActor("metrics")), name = "metrics") 

metricActor ! message works fine 

writeFiles(metricActor) //writeFiles is in another class 


writeFiles(actor: ActorRef) { 
    f.forEach(v => { 
    actor ! message // this doesn't seem to work 
}) 
} 

Edited предоставить больше кода.

полный пример ClassB, как это было

def writeFiles(bucket: String, filesToWrite: RDD[(String, String)], actor:ActorRef): Unit = 
filesToWrite.foreachPartition(f => { 
    f.foreach(v => { 
    try { 
     //actor ! ProcessSingleItem(MetricItem("File Created")) 
     logger.debug(s"Writing file:") 
     writeFile() 
    } 
    catch { 
     case e: Exception => 
     //actor ! ProcessSingleItem(CloudWatchMetricItem("File create failure")) 
     logger.error("Error creating file", e) 
    } 
    }) 
}) 

Answer 1

То, что вы описываете должны работать. Вы не ввели полный (но минимальный!) Образец кода, поэтому я не могу сказать, в чем проблема (возможно, что-то в вашей логике foreach, мы даже не знаем, что такое f), но вот что определенно работает. Постарайтесь это сделать.

object Test extends App { 

    class MetricActor extends Actor { 
    def receive = { 
     case a: String => println(a) 
    } 
    } 

    private val system = ActorSystem("System") 
    private val metricActor= system.actorOf(Props(new MetricActor()), name = "metrics") 

    OtherClass.writeFiles(metricActor) // prints "foo" 
} 

// this is in other file: 
object OtherClass { 
    def writeFiles(actor: ActorRef) { 
    actor ! "foo" 
    } 
} 

EDIT: Оказывается, после обсуждения в комментариях, что проблематичная часть была связана с Акки (попробуйте блок даже не выполняет), но я оставлю это здесь, в случае кто-то помогает.