Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 32C1019C34 for ; Mon, 21 Mar 2016 16:14:35 +0000 (UTC) Received: (qmail 93095 invoked by uid 500); 21 Mar 2016 16:14:35 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 92997 invoked by uid 500); 21 Mar 2016 16:14:34 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 92988 invoked by uid 99); 21 Mar 2016 16:14:34 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 21 Mar 2016 16:14:34 +0000 Received: from [192.168.1.110] (ip5b40315a.dynamic.kabel-deutschland.de [91.64.49.90]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 4CDED1A003F for ; Mon, 21 Mar 2016 16:14:34 +0000 (UTC) Subject: Re: Unable to run the batch examples after running stream examples To: user@flink.apache.org References: From: Chesnay Schepler Message-ID: <56F01DFB.8020808@apache.org> Date: Mon, 21 Mar 2016 17:14:51 +0100 User-Agent: Mozilla/5.0 (Windows NT 10.0; WOW64; rv:38.0) Gecko/20100101 Thunderbird/38.5.0 MIME-Version: 1.0 In-Reply-To: Content-Type: multipart/alternative; boundary="------------070106060903000904020808" This is a multi-part message in MIME format. --------------070106060903000904020808 Content-Type: text/plain; charset=utf-8; format=flowed Content-Transfer-Encoding: 7bit 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 > --------------070106060903000904020808 Content-Type: text/html; charset=utf-8 Content-Transfer-Encoding: 8bit
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


--------------070106060903000904020808--