It was not really mean to be hidden. So its essentially the case of the
documentation being insufficient. This code has not gotten much attention
for a while, so it could have a bugs. If you find any and submit a fix for
them, I am happy to take a look!
TD
On Thu, Jan 8, 2015 at 6:33 PM, Nan Zhu
Hi,
I have created the PR for these two issues
Best,
--
Nan Zhu
http://codingcat.me
On Friday, January 9, 2015 at 7:38 AM, Nan Zhu wrote:
Thanks, TD,
I just created 2 JIRAs to track these,
https://issues.apache.org/jira/browse/SPARK-5174
Hi, TD and other streaming developers,
When I look at the implementation of actor-based receiver
(ActorReceiver.scala), I found that there are several messages which are not
mentioned in the document
case props: Props =
val worker = context.actorOf(props)
logInfo(Started receiver worker at:
