Hi, I did not create anything by myself. I just downloaded the files from here: https://github.com/tillrohrmann/flink-perf <https://github.com/tillrohrmann/flink-perf>
And then executed mvn clean install -DskipTests Then I opened the project within IntelliJ and there it works fine. Then I exported it to the cluster that runs with 0.10-SNAPSHOT. > Am 02.10.2015 um 12:15 schrieb Stephan Ewen <se...@apache.org>: > > @Lydia Did you create your POM files for your job with an 0.8.x quickstart? > > Can you try to simply re-create your project's POM files with a new > quickstart? > > I think that the POMS between 0.8-incubating-SNAPSHOT and 0.10-SNAPSHOT may > not be quite compatible any more... > > On Fri, Oct 2, 2015 at 12:07 PM, Robert Metzger <rmetz...@apache.org > <mailto:rmetz...@apache.org>> wrote: > Are you relying on a feature only available in 0.10-SNAPSHOT? > Otherwise, I would recommend to use the latest stable release (0.9.1) for > your flink job and on the cluster. > > On Fri, Oct 2, 2015 at 11:55 AM, Lydia Ickler <ickle...@googlemail.com > <mailto:ickle...@googlemail.com>> wrote: > Hi, > > but inside the pom of flunk-job is the flink version set to 0.8 > > <flink.version>0.8-incubating-SNAPSHOT</flink.version> > > how can I change it to the newest? > <flink.version>0.10-SNAPSHOT</flink.version> > Is not working > >> Am 02.10.2015 um 11:48 schrieb Robert Metzger <rmetz...@apache.org >> <mailto:rmetz...@apache.org>>: >> >> 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 >> <mailto: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 >> >> > > >
