Hello Kostas, Thanks for you reply.
I don't think that is the case because I am running the application on the jvm of my local machine, not on a distributed cluster. Any other input? Warm Regards, Debaditya On Thu, Jun 2, 2016 at 1:27 PM, Kostas Kloudas <k.klou...@data-artisans.com> wrote: > Hello Debaditya, > > From the exception message you posted it seems that it is a linkage error. > > Could it be that you are combining different versions of Flink when > running your application? > E.g. you have version X running on your cluster and you create your jar > against version Y on your local machine? > In this case, Flink version Y may have a method that is no longer there in > version X, and this causes the > exception. > > Kostas > > On Jun 2, 2016, at 12:02 PM, Debaditya Roy <roydca...@gmail.com> wrote: > > Hi, > > I am trying to run a simple flink program, which reads an image from disk > and does some image processing and stores it back to the disk. For the > purpose I have a custom defined class, which I am using in dataset and > passing it onwards to flatmap function. However the experiment encountered > an error which I am clueless about. Any help will be highly appreciated. > Pasting the error below. > > > > > > > > > > > > > *Exception in thread "main" java.lang.NoSuchMethodError: > org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.recursivelyRegisterType(Ljava/lang/Class;Lorg/apache/flink/api/common/ExecutionConfig;)V > at > org.apache.flink.api.java.ExecutionEnvironment$1.preVisit(ExecutionEnvironment.java:985) > at > org.apache.flink.api.java.ExecutionEnvironment$1.preVisit(ExecutionEnvironment.java:977) > at > org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:198) > at > org.apache.flink.api.common.operators.GenericDataSinkBase.accept(GenericDataSinkBase.java:223) > at org.apache.flink.api.common.Plan.accept(Plan.java:348) at > org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:977) > at > org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:938) > at > org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:80) > at > org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:834) > at org.apache.flink.api.java.DataSet.collect(DataSet.java:408) at > org.myorg.quickstart.Job.main(Job.java:51)* > > Warm Regards, > Debaditya > > >
