Getting java.lang.IllegalArgumentException: requirement failed while calling Sparks MLLIB StreamingKMeans from java application

[Yogesh Vyas <in...@gmail.com>]

Hi,
 I am trying to run a KMeansStreaming from the Java application, but
it gives the following error:

"Getting java.lang.IllegalArgumentException: requirement failed while
calling Sparks MLLIB StreamingKMeans from java application"

Below is my code:

JavaDStream<Vector> v = trainingData.map(new Function<String,Vector>() {

public Vector call(String arg0) throws Exception {
// TODO Auto-generated method stub
String[] p = arg0.split(",");
double[] d = new double[p.length] ;
for(int i=0;i<p.length;i++) {
d[i]=(Double.parseDouble(p[i]));
}
return Vectors.dense(d);
}
});

int numDimensions = 3;
int numClusters = 2;
StreamingKMeans model = new StreamingKMeans();
model.setK(numClusters);
model.setDecayFactor(1);
model.setRandomCenters(nnumDimensions, 0, 0);

model.trainOn(trainingData.dstream());

---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscribe@spark.apache.org
For additional commands, e-mail: user-help@spark.apache.org