required: org.apache.spark.streaming.dstream.DStream[org.apache.spark.mllib.linalg.Vector]

[Arthur Chan]

Hi,

I am trying Spark with some sample programs,


In my code, the following items are imported:

import org.apache.spark.mllib.regression.{StreamingLinearRegressionWithSGD,
LabeledPoint}

import org.apache.spark.mllib.regression.{StreamingLinearRegressionWithSGD}

import org.apache.spark.streaming.{Seconds, StreamingContext}

import scala.util.Random

I got following error:

[error] StreamingModel.scala:100: type mismatch;

[error]  found   :
org.apache.spark.streaming.dstream.DStream[org.apache.spark.mllib.regression.LabeledPoint]

[error]  required:
org.apache.spark.streaming.dstream.DStream[org.apache.spark.mllib.linalg.Vector]

[error]     model.predictOn(labeledStream).print()

[error]                     ^

[error] one error found

[error] (compile:compile) Compilation failed


Any idea?


Regards