spark-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Brian London (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (SPARK-12786) Actor demo does not demonstrate usable code
Date Fri, 15 Jan 2016 15:29:39 GMT

    [ https://issues.apache.org/jira/browse/SPARK-12786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15101918#comment-15101918
] 

Brian London edited comment on SPARK-12786 at 1/15/16 3:29 PM:
---------------------------------------------------------------

Yeah, exactly.  Because of the use of {{AkkaUtil}} the settings needed to create a minimal
actor system that can communicate with the actor stream is buried in the Spark code.

I believe the change at https://github.com/apache/spark/pull/10744/files#diff-690ab3eacd0a42fe7bee1d29c5910ffdR111
will resolve this issue.

On a side note, are there plans to include classes to use actors as a DStream output as well?


was (Author: brianlondon):
Yeah, exactly.  Because of the use of `AkkaUtil` the settings needed to create a minimal actor
system that can communicate with the actor stream is buried in the Spark code.

I believe the change at https://github.com/apache/spark/pull/10744/files#diff-690ab3eacd0a42fe7bee1d29c5910ffdR111
will resolve this issue.

On a side note, are there plans to include classes to use actors as a DStream output as well?

> Actor demo does not demonstrate usable code
> -------------------------------------------
>
>                 Key: SPARK-12786
>                 URL: https://issues.apache.org/jira/browse/SPARK-12786
>             Project: Spark
>          Issue Type: Documentation
>          Components: Streaming
>    Affects Versions: 1.5.2, 1.6.0
>            Reporter: Brian London
>            Priority: Minor
>
> The ActorWordCount demo doesn't show how to set up an actor based dstream in a way that
can be used.  
> The demo relies on the {{AkkaUtils}} object, which is marked private[spark].  Thus the
code presented will not compile unless users declare their code to be in the org.apache.spark
package. 
> Demo is located at https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org


Mime
View raw message