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 Thu, 24 Mar 2016 14:58:47 GMT
the project.version property is not defined explicitly; it resembles the 
version of the parent.

Plan#getRestartStrategyConfiguration() exists in Flink 1.0.0, but not in 
1.1-SNAPSHOT.

When you set the version to 1.0.0 you may have created this version 
mismatch.

On 21.03.2016 19:23, subash basnet wrote:
> Hello Chesnay Schepler,
>
> I am running the latest flink examples from here 
> <https://github.com/apache/flink> in eclipse.
> I had used the WikipediaAnalysis pom properties/dependency in batch 
> pom as shown below:
>             <properties>
> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> <flink.version>1.0.0</flink.version>
>           </properties>
>           <dependency>
> <groupId>org.apache.flink</groupId>
> <artifactId>flink-java</artifactId>
> *<version>1.0.0</version>*
> </dependency>
> <dependency>
> <groupId>org.apache.flink</groupId>
> <artifactId>flink-streaming-java_2.10</artifactId>
> <version>${flink.version}</version>
> </dependency>
>
> But the original pom of batch has dependency:
>                 <dependency>
> <groupId>org.apache.flink</groupId>
> <artifactId>flink-java</artifactId>
> *<version>${project.version}</version>*
> </dependency>
>
> Shouldn't both the above mean the same? I couldn't find the pom file 
> where 'project.version' property was defined. Yeah it's working when I 
> used the original pom of batch, but I am confused why the modified one 
> is not working.
>
> Best Regards,
> Subash Basnet
>
>
> On Mon, Mar 21, 2016 at 5:14 PM, Chesnay Schepler <chesnay@apache.org 
> <mailto:chesnay@apache.org>> wrote:
>
>     Boxbe <https://www.boxbe.com/overview> This message is eligible
>     for Automatic Cleanup! (chesnay@apache.org
>     <mailto:chesnay@apache.org>) Add cleanup rule
>     <https://www.boxbe.com/popup?url=https%3A%2F%2Fwww.boxbe.com%2Fcleanup%3Ftoken%3Dlkiao%252FbvApkYqR3nqgNVFpcfEX3rRIVrEPiCy4Hab8YcKwvYpNB0bqFNuTlLTr%252FQNtDMtcXWOSffNjJHUkn0klwJ4M3RlFAkIHSZGZrQMF70ZHyyE0PpKtd4%252BQPJC0Sg3rovM8bg3iQ%253D%26key%3DuknwPP5FGaZFx41nEpUkUuHOEI915LlL13L4F1BY%252F4o%253D&tc_serial=24800110698&tc_rand=287469002&utm_source=stf&utm_medium=email&utm_campaign=ANNO_CLEANUP_ADD&utm_content=001>
>     | More info
>     <http://blog.boxbe.com/general/boxbe-automatic-cleanup?tc_serial=24800110698&tc_rand=287469002&utm_source=stf&utm_medium=email&utm_campaign=ANNO_CLEANUP_ADD&utm_content=001>
>
>
>     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