Can it works in load the MatrixFactorizationModel and predict product with Spark Streaming?

I have finish training MatrixFactorizationModel, I want to load this model in spark-streaming. I think it can be works, but actually not. I don't know why, who can help me? I wrote code like this: val ssc = new StreamingContext ... val bestModel =

Re: Can it works in load the MatrixFactorizationModel and predict product with Spark Streaming?

The logs have told you what cause the error that you can not invoke RDD transformations and actions in other transformations. You have not do this explicitly but the implementation of MatrixFactorizationModel .recommendProducts do that, you can refer