The scenario is I am working on Kafka Read/Write examples.
It works fine, but now when I try to run the batch examples
such as PiEstimation or any other, I get the following error:
Exception in thread "main" java.lang.NoSuchMethodError:
org.apache.flink.api.common.Plan.getRestartStrategyConfiguration()Lorg/apache/flink/api/common/restartstrategy/RestartStrategies$RestartStrategyConfiguration;
at
org.apache.flink.optimizer.plantranslate.JobGraphGenerator.compileJobGraph(JobGraphGenerator.java:222)
at
org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:187)
at
org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:90)
at
org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855)
at
org.apache.flink.api.java.DataSet.collect(DataSet.java:410)
at
org.apache.flink.examples.java.misc.PiEstimation.main(PiEstimation.java:63)
Previously before running the Kafka examples, the batch
examples were working fine, now not. Now only the streaming
examples are working.
Best Regards,
Subash Basnet