You are viewing a plain text version of this content. The canonical link for it is here.
Posted to reviews@spark.apache.org by jaceklaskowski <gi...@git.apache.org> on 2016/01/05 13:57:30 UTC

[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

GitHub user jaceklaskowski opened a pull request:

    https://github.com/apache/spark/pull/10603

    [STREAMING][DOCS][EXAMPLES] Minor fixes

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/jaceklaskowski/spark streaming-actor-custom-receiver

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/spark/pull/10603.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #10603
    
----
commit 5629feb2f43df706f0664b67c098d11a3c0b7185
Author: Jacek Laskowski <ja...@japila.pl>
Date:   2016-01-05T12:55:25Z

    [STREAMING][DOCS][EXAMPLES] Minor fixes

----


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by jaceklaskowski <gi...@git.apache.org>.
Github user jaceklaskowski commented on a diff in the pull request:

    https://github.com/apache/spark/pull/10603#discussion_r48852732
  
    --- Diff: docs/streaming-custom-receivers.md ---
    @@ -273,9 +273,9 @@ class CustomActor extends Actor with ActorHelper {
     And a new input stream can be created with this custom actor as
     
     {% highlight scala %}
    -// Assuming ssc is the StreamingContext
    -val lines = ssc.actorStream[String](Props(new CustomActor()), "CustomReceiver")
    +val ssc: StreamingContext = ...
    +val lines = ssc.actorStream[String](Props[CustomActor], "CustomReceiver")
     {% endhighlight %}
     
     See [ActorWordCount.scala](https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala)
    -for an end-to-end example.
    +for a complete example.
    --- End diff --
    
    It was discussed, but the changes are a result of my daily code reviews and I don't really know where I end up ahead. I'm now in Streaming so I will...*batch*...more changes next time.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by srowen <gi...@git.apache.org>.
Github user srowen commented on a diff in the pull request:

    https://github.com/apache/spark/pull/10603#discussion_r48844388
  
    --- Diff: docs/streaming-custom-receivers.md ---
    @@ -273,9 +273,9 @@ class CustomActor extends Actor with ActorHelper {
     And a new input stream can be created with this custom actor as
     
     {% highlight scala %}
    -// Assuming ssc is the StreamingContext
    -val lines = ssc.actorStream[String](Props(new CustomActor()), "CustomReceiver")
    +val ssc: StreamingContext = ...
    +val lines = ssc.actorStream[String](Props[CustomActor], "CustomReceiver")
     {% endhighlight %}
     
     See [ActorWordCount.scala](https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala)
    -for an end-to-end example.
    +for a complete example.
    --- End diff --
    
    This was OK as-is; the rest looks OK. Again, can you batch together more changes? this is a lot of little PRs, and this has been discussed several times before


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:

    https://github.com/apache/spark/pull/10603


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/10603#issuecomment-169281734
  
    **[Test build #2333 has finished](https://amplab.cs.berkeley.edu/jenkins/job/NewSparkPullRequestBuilder/2333/consoleFull)** for PR 10603 at commit [`07cdc9e`](https://github.com/apache/spark/commit/07cdc9ef5e1e567affa53154bd4b74c00c75b739).
     * This patch passes all tests.
     * This patch merges cleanly.
     * This patch adds no public classes.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by rxin <gi...@git.apache.org>.
Github user rxin commented on the pull request:

    https://github.com/apache/spark/pull/10603#issuecomment-169581173
  
    Other than that one line, rest LGTM.



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by rxin <gi...@git.apache.org>.
Github user rxin commented on a diff in the pull request:

    https://github.com/apache/spark/pull/10603#discussion_r49047004
  
    --- Diff: docs/streaming-custom-receivers.md ---
    @@ -257,9 +257,9 @@ The following table summarizes the characteristics of both types of receivers
     
     ## Implementing and Using a Custom Actor-based Receiver
     
    -Custom [Akka Actors](http://doc.akka.io/docs/akka/2.2.4/scala/actors.html) can also be used to
    +Custom [Akka Actors](http://doc.akka.io/docs/akka/current/scala/actors.html) can also be used to
    --- End diff --
    
    linking to current seem like a bad idea given they could have api breaking changes?



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by jaceklaskowski <gi...@git.apache.org>.
Github user jaceklaskowski commented on a diff in the pull request:

    https://github.com/apache/spark/pull/10603#discussion_r49048172
  
    --- Diff: docs/streaming-custom-receivers.md ---
    @@ -257,9 +257,9 @@ The following table summarizes the characteristics of both types of receivers
     
     ## Implementing and Using a Custom Actor-based Receiver
     
    -Custom [Akka Actors](http://doc.akka.io/docs/akka/2.2.4/scala/actors.html) can also be used to
    +Custom [Akka Actors](http://doc.akka.io/docs/akka/current/scala/actors.html) can also be used to
    --- End diff --
    
    It's about actors which are the fundamental concept of Akka so it's of less worry (like RDDs in Spark), but have changed it to the Akka version Spark uses, i.e. `2.3.11`.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by rxin <gi...@git.apache.org>.
Github user rxin commented on the pull request:

    https://github.com/apache/spark/pull/10603#issuecomment-169594040
  
    I've merged this.



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by AmplabJenkins <gi...@git.apache.org>.
Github user AmplabJenkins commented on the pull request:

    https://github.com/apache/spark/pull/10603#issuecomment-168992549
  
    Can one of the admins verify this patch?


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/10603#issuecomment-169278726
  
    **[Test build #2333 has started](https://amplab.cs.berkeley.edu/jenkins/job/NewSparkPullRequestBuilder/2333/consoleFull)** for PR 10603 at commit [`07cdc9e`](https://github.com/apache/spark/commit/07cdc9ef5e1e567affa53154bd4b74c00c75b739).


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/10603#issuecomment-169592694
  
    **[Test build #2344 has finished](https://amplab.cs.berkeley.edu/jenkins/job/NewSparkPullRequestBuilder/2344/consoleFull)** for PR 10603 at commit [`7f215fc`](https://github.com/apache/spark/commit/7f215fcdf4c8682e8ddceb57c25f288272f681dc).
     * This patch passes all tests.
     * This patch merges cleanly.
     * This patch adds no public classes.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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


[GitHub] spark pull request: [STREAMING][DOCS][EXAMPLES] Minor fixes

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/10603#issuecomment-169590061
  
    **[Test build #2344 has started](https://amplab.cs.berkeley.edu/jenkins/job/NewSparkPullRequestBuilder/2344/consoleFull)** for PR 10603 at commit [`7f215fc`](https://github.com/apache/spark/commit/7f215fcdf4c8682e8ddceb57c25f288272f681dc).


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

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