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

Reply via email to