flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Unable to run the batch examples after running stream examples
Date Mon, 21 Mar 2016 16:14:51 GMT
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
>


Mime
View raw message