flink-user mailing list archives

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