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
