Github user CodingCat closed the pull request at:
https://github.com/apache/spark/pull/10892
---
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
Github user zsxwing commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-200991376
@CodingCat could you close this PR since streaming-akka has been moved out?
Sorry for the convenience.
---
If your project is set up for it, you can reply to this emai
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-176731470
Merged build finished. Test PASSed.
---
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 projec
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-176731472
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-176731298
**[Test build #50379 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50379/consoleFull)**
for PR 10892 at commit
[`e985b41`](https://g
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-176727700
**[Test build #50379 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50379/consoleFull)**
for PR 10892 at commit
[`e985b41`](https://gi
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-176726936
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-176726929
Merged build finished. Test FAILed.
---
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 projec
Github user CodingCat commented on a diff in the pull request:
https://github.com/apache/spark/pull/10892#discussion_r51253465
--- Diff:
external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala
---
@@ -90,6 +90,48 @@ object ActorReceiver {
@DeveloperAp
Github user CodingCat commented on a diff in the pull request:
https://github.com/apache/spark/pull/10892#discussion_r51253306
--- Diff:
external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala
---
@@ -202,12 +294,11 @@ private[akka] case class ByteBufferDa
Github user CodingCat commented on a diff in the pull request:
https://github.com/apache/spark/pull/10892#discussion_r51252908
--- Diff:
external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala
---
@@ -90,6 +90,48 @@ object ActorReceiver {
@DeveloperAp
Github user ScrapCodes commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-176122545
@CodingCat and @zsxwing Thanks for the PR and letting me take a look, I am
a bit unsure about having these as API methods. I want to know what others
opinion is on t
Github user ScrapCodes commented on a diff in the pull request:
https://github.com/apache/spark/pull/10892#discussion_r51106802
--- Diff:
external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala
---
@@ -90,6 +90,48 @@ object ActorReceiver {
@DeveloperA
Github user ScrapCodes commented on a diff in the pull request:
https://github.com/apache/spark/pull/10892#discussion_r51083142
--- Diff:
external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala
---
@@ -202,12 +294,11 @@ private[akka] case class ByteBufferD
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174956449
Merged build finished. Test PASSed.
---
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 projec
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174956456
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174956213
**[Test build #50098 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50098/consoleFull)**
for PR 10892 at commit
[`c3981da`](https://g
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174952472
**[Test build #50098 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50098/consoleFull)**
for PR 10892 at commit
[`c3981da`](https://gi
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174938184
Merged build finished. Test PASSed.
---
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 projec
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174938186
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174937906
**[Test build #50092 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50092/consoleFull)**
for PR 10892 at commit
[`3785377`](https://g
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174932509
**[Test build #50092 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50092/consoleFull)**
for PR 10892 at commit
[`3785377`](https://gi
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/10892#discussion_r50739141
--- Diff:
external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala
---
@@ -140,6 +181,48 @@ abstract class ActorReceiver extends Act
Github user zsxwing commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174622519
Could you document Statistics.numberOfMsgs? The previous meaning of it is
really confusing.
Ping @ScrapCodes to take a look since you wrote the previous codes.
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174384503
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174384499
Merged build finished. Test PASSed.
---
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 projec
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174384312
**[Test build #49966 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/49966/consoleFull)**
for PR 10892 at commit
[`ffd1d02`](https://g
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174383807
Merged build finished. Test PASSed.
---
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 projec
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174383809
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174383634
**[Test build #49963 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/49963/consoleFull)**
for PR 10892 at commit
[`2799982`](https://g
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174382540
**[Test build #49966 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/49966/consoleFull)**
for PR 10892 at commit
[`ffd1d02`](https://gi
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174381976
**[Test build #49963 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/49963/consoleFull)**
for PR 10892 at commit
[`2799982`](https://gi
Github user CodingCat commented on the pull request:
https://github.com/apache/spark/pull/10892#issuecomment-174380370
@zsxwing mind having a review?
---
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 no
GitHub user CodingCat opened a pull request:
https://github.com/apache/spark/pull/10892
[SPARK-5174][SPARK-5175] add more APIs to actorReceiver
there are some implemented, yet hidden from user, functionality, in
ActorReceiver, e.g. create more receiver actors, message statistics
34 matches
Mail list logo
