[
https://issues.apache.org/jira/browse/SPARK-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137529#comment-14137529
]
kannapiran commented on SPARK-2593:
-----------------------------------
Is there a way to add akka system in to spark streaming context and write the
output to hdfs from spark streaming.
I tried
ActorReceiver rec = new ActorReceiver(props, "TestActor",
StorageLevel.MEMORY_AND_DISK_2(), SupervisorStrategy.defaultStrategy(), null);
ReceiverInputDStream<Object> receiverStream = context.receiverStream(rec, null);
receiverStream.print();
But the above code doesnt stream anything from actor system
> Add ability to pass an existing Akka ActorSystem into Spark
> -----------------------------------------------------------
>
> Key: SPARK-2593
> URL: https://issues.apache.org/jira/browse/SPARK-2593
> Project: Spark
> Issue Type: Improvement
> Components: Spark Core
> Reporter: Helena Edelson
>
> As a developer I want to pass an existing ActorSystem into StreamingContext
> in load-time so that I do not have 2 actor systems running on a node in an
> Akka application.
> This would mean having spark's actor system on its own named-dispatchers as
> well as exposing the new private creation of its own actor system.
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
