Hi,
I am writing pyspark stream program. I have the training data set to
compute the regression model. I want to use the stream data set to
test the model. So, I join with RDD with the StreamRDD, but i got the
exception. Following are my source code, and the exception I got. Any
help is
This seems be a bug, could you file a JIRA for it?
RDD should be serializable for Streaming job.
On Thu, Jun 18, 2015 at 4:25 AM, Groupme grou...@gmail.com wrote:
Hi,
I am writing pyspark stream program. I have the training data set to compute
the regression model. I want to use the stream