Re: data flow example on cluster

Posted by Lydia Ickler on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/data-flow-example-on-cluster-tp2963p2996.html

Hi Till,

I want to execute your Matrix Completion program „ALSJoin“.

Locally it works perfect.

Now I want to execute it on the cluster with:

run -c com.github.projectflink.als.ALSJoin -cp /tmp/icklerly/flink-jobs-0.1-SNAPSHOT.jar 0 2 0.001 10 1 1

but I get the following error:

java.lang.NoSuchMethodError: org.apache.flink.api.scala.typeutils.CaseClassTypeInfo.<init>(Ljava/lang/Class;Lscala/collection/Seq;Lscala/collection/Seq;)V

I guess something like the flink-scala-0.10-SNAPSHOT.jar is missing.

How can I add that to the path?

Best regards,

Lydia