无法反序列化ActorRef发送结果不同的演员

编程入门 行业动态 更新时间:2024-10-12 08:22:29
本文介绍了无法反序列化ActorRef发送结果不同的演员的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧! 问题描述

我开始使用星火流处理实时数据馈送我得​​到。我的情况是我必须用同ActorHelper一个演员阿卡接收器的话,我有我的工作星火做一些映射和转换,然后我想将结果发送给另一个演员。

I am starting to use Spark Streaming to process a real time data feed I am getting. My scenario is I have a Akka actor receiver using "with ActorHelper", then I have my Spark job doing some mappings and transformation and then I want to send the result to another actor.

我的问题是最后一部分。当试图发​​送到另一个演员Spark是引发异常:

My issue is the last part. When trying to send to another actor Spark is raising an exception:

15/02/20 16时43分16秒WARN TaskSetManager:在第一阶段2.0迷失任务0.0(TID 2,本地主机):java.lang.IllegalStateException:尝试反序列化序列化ActorRef没有范围的ActorSystem。使用akka.serialization.Serialization.currentSystem.withValue(系统){...}

15/02/20 16:43:16 WARN TaskSetManager: Lost task 0.0 in stage 2.0 (TID 2, localhost): java.lang.IllegalStateException: Trying to deserialize a serialized ActorRef without an ActorSystem in scope. Use 'akka.serialization.Serialization.currentSystem.withValue(system) { ... }'

我创造这最后男主角的方法如下:

The way I am creating this last actor is the following:

val actorSystem = SparkEnv.get.actorSystem val lastActor = actorSystem.actorOf(MyLastActor.props(someParam), "MyLastActor")

,然后用它是这样的:

And then using it like this:

result.foreachRDD(rdd => rdd.foreachPartition(lastActor ! _))

我不知道在哪里,怎么办劝使用'akka.serialization.Serialization.currentSystem.withValue(系统){...}'。我是否需要设置什么特别通过配置?或不同的创建我的演员?

I am not sure where or how to do the advise "Use 'akka.serialization.Serialization.currentSystem.withValue(system) { ... }'". Do I need to set anything special through configuration? Or create my actor differently?

推荐答案

我发现,如果我收集之前,我发送给它就像一个魅力的演员:

I found that if I collect before I send to the actor it works like a charm:

result.foreachRDD(rdd => rdd.collect().foreach(producer ! _))

更多推荐

无法反序列化ActorRef发送结果不同的演员

本文发布于:2023-11-25 02:33:41,感谢您对本站的认可!
本文链接:https://www.elefans.com/category/jswz/34/1627974.html
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
本文标签:演员   序列化   ActorRef

发布评论

评论列表 (有 0 条评论)
草根站长

>www.elefans.com

编程频道|电子爱好者 - 技术资讯及电子产品介绍!