[
https://issues.apache.org/jira/browse/BAHIR-64?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15630617#comment-15630617
]
ASF GitHub Bot commented on BAHIR-64:
-------------------------------------
Github user ckadner commented on a diff in the pull request:
https://github.com/apache/bahir/pull/24#discussion_r86248567
--- Diff:
streaming-akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala
---
@@ -65,6 +65,7 @@ object ActorReceiver {
val akkaConf = ConfigFactory.parseString(
s"""akka.actor.provider = "akka.remote.RemoteActorRefProvider"
|akka.remote.enabled-transports = ["akka.remote.netty.tcp"]
+ |akka.remote.netty.tcp.port = "0"
--- End diff --
we set it to `"0"` to have the port chosen automatically for the _Feeder_
actor and the _Receiver_ actor will "pick it up" when it subscribes to the
_Feeder_ actor [Akka Remoting
docs](http://doc.akka.io/docs/akka/2.3.11/scala/remoting.html#Preparing_your_ActorSystem_for_Remoting)
> Add test that Akka streaming connector can receive data
> -------------------------------------------------------
>
> Key: BAHIR-64
> URL: https://issues.apache.org/jira/browse/BAHIR-64
> Project: Bahir
> Issue Type: Sub-task
> Components: Spark Streaming Connectors
> Reporter: Christian Kadner
> Assignee: Christian Kadner
> Labels: test
>
> Add test cases that verify that the *Akka streaming connector* can receive
> streaming data.
> See [BAHIR-63|https://issues.apache.org/jira/browse/BAHIR-63]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
