[
https://issues.apache.org/jira/browse/BAHIR-64?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15626719#comment-15626719
]
ASF GitHub Bot commented on BAHIR-64:
-------------------------------------
Github user lresende commented on a diff in the pull request:
https://github.com/apache/bahir/pull/24#discussion_r83520719
--- 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 --
Why are setting this to any available port ? Don't they need to match
between the client and server ?
> 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)
