Hello all, 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
