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

2015-06-28 Thread Ted Yu
] 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

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

2015-06-28 Thread Arthur Chan
: 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

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

2015-06-28 Thread Arthur Chan
: 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

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

2015-06-28 Thread Feynman Liang
, 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