flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Kloudas <k.klou...@data-artisans.com>
Subject Re: Exception in thread main: No such exception errpr
Date Thu, 02 Jun 2016 11:27:36 GMT
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 


> On Jun 2, 2016, at 12:02 PM, Debaditya Roy <roydcat14@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

View raw message