Hi,

I know i am asking again, but I tried running the same thing on mac as well
as some answers on the internet suggested it could be an issue with the
windows environment, but still nothing works.

Can anyone atleast suggest whether its a bug with spark or is it something
else?

Would be really grateful! Thanks a lot.

Thanks & Regards
Biplob Biswas

On Thu, Jul 7, 2016 at 5:21 PM, Biplob Biswas <revolutioni...@gmail.com>
wrote:

> Hi,
>
> Can anyone care to please look into this issue?  I would really love some
> assistance here.
>
> Thanks a lot.
>
> Thanks & Regards
> Biplob Biswas
>
> On Tue, Jul 5, 2016 at 1:00 PM, Biplob Biswas <revolutioni...@gmail.com>
> wrote:
>
>>
>> Hi,
>>
>> I implemented the streamingKmeans example provided in the spark website
>> but
>> in Java.
>> The full implementation is here,
>>
>> http://pastebin.com/CJQfWNvk
>>
>> But i am not getting anything in the output except occasional timestamps
>> like one below:
>>
>> -------------------------------------------
>> Time: 1466176935000 ms
>> -------------------------------------------
>>
>> Also, i have 2 directories:
>> "D:\spark\streaming example\Data Sets\training"
>> "D:\spark\streaming example\Data Sets\test"
>>
>> and inside these directories i have 1 file each "samplegpsdata_train.txt"
>> and "samplegpsdata_test.txt" with training data having 500 datapoints and
>> test data with 60 datapoints.
>>
>> I am very new to the spark systems and any help is highly appreciated.
>>
>>
>> //---------------------------------------------------------------------------------------//
>>
>> Now, I also have now tried using the scala implementation available here:
>>
>> https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/mllib/StreamingKMeansExample.scala
>>
>>
>> and even had the training and test file provided in the format specified
>> in
>> that file as follows:
>>
>>  * The rows of the training text files must be vector data in the form
>>  * `[x1,x2,x3,...,xn]`
>>  * Where n is the number of dimensions.
>>  *
>>  * The rows of the test text files must be labeled data in the form
>>  * `(y,[x1,x2,x3,...,xn])`
>>  * Where y is some identifier. n must be the same for train and test.
>>
>>
>> But I still get no output on my eclipse window ... just the Time!
>>
>> Can anyone seriously help me with this?
>>
>> Thank you so much
>> Biplob Biswas
>>
>>
>>
>> --
>> View this message in context:
>> http://apache-spark-user-list.1001560.n3.nabble.com/StreamingKmeans-Spark-doesn-t-work-at-all-tp27286.html
>> Sent from the Apache Spark User List mailing list archive at Nabble.com.
>>
>> ---------------------------------------------------------------------
>> To unsubscribe e-mail: user-unsubscr...@spark.apache.org
>>
>>
>

Reply via email to