where did you run the batch/streaming jobs? did both job use the same
flink version?
On 21.03.2016 17:06, subash basnet wrote:
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
