Hi,
line 99: model.trainOn(labeledStream) line 100: model.predictOn(labeledStream).print() line 101: ssc.start() line 102: ssc.awaitTermination() Regards On Sun, Jun 28, 2015 at 10:53 PM, Ted Yu <[email protected]> wrote: > Can you show us your code around line 100 ? > > Which Spark release are you compiling against ? > > Cheers > > On Sun, Jun 28, 2015 at 5:49 AM, Arthur Chan <[email protected]> > wrote: > >> 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 >> > >
