I think there is a version mismatch between the Flink version you've used to compile your job and the Flink version installed on the cluster.
Maven automagically pulls newer 0.10-SNAPSHOT versions every time you're building your job. On Fri, Oct 2, 2015 at 11:45 AM, Lydia Ickler <ickle...@googlemail.com> wrote: > 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 > >
