also my Spark is 1.4
On Mon, Jun 29, 2015 at 9:02 AM, Arthur Chan <arthur.hk.c...@gmail.com>
wrote:
>
>
> 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 <yuzhih...@gmail.com> 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 <arthur.hk.c...@gmail.com>
>> 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
>>>
>>
>>
>
