Hi,

Something is wrong with my spark subscription so I can't see the responses
properly on nabble, so I subscribed from a different id, hopefully it is
solved and I am putting my question again here.

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 have already tried putting the data files after starting the code but
still no output, i am also not getting any exception or anything, so its
hard to debug for me.

I am very new to the spark systems and any help is highly appreciated.

Thank you so much
Biplob Biswas

Reply via email to