Suppose my mappers can be functions (def) that internally call other classes
and create objects and do different things inside. (Or they can even be
classes that extend (Foo) = Bar and do the processing in their apply method
- but let's ignore this case for now)
Spark supports only Java
Thanks for sending this in.
The ASF list doesn't support html so the formatting of the code is a little
messed up. For those who want to see the code in clearly formatted text, go
to
http://apache-spark-developers-list.1001551.n3.nabble.com/Kryo-serialization-for-closures-a-workaround-tp6787.html
I looked at the Streaming UI for my job and it reports that it has
processed many batches, but that none of the batches had any records in
them. Unfortunately, that’s what I expected. :-(
I’ve tried multiple test programs and I’m seeing the same thing. The
Kafka sources are alive and well and
What does the kafka receiver status on the streaming UI say when you are
connected to the Kafka sources? Does it show any error?
Can you find out which machine the receiver is running and see the worker
logs for any exceptions / error messages? Try turning on the DEBUG level in
log4j.
TD
On May
