flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Debaditya Roy <roydca...@gmail.com>
Subject Re: Exception in thread main: No such exception errpr
Date Thu, 02 Jun 2016 12:01:40 GMT
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.kloudas@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 <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
>
>
>

Mime
View raw message