Yes Robert ,
i was trying to start Flink on cluster 0.10.1.
But after changing flink version to 0.10.1 , also i am getting the same
error.
On Sat, Feb 27, 2016 at 2:47 PM, Robert Metzger <rmetz...@apache.org> wrote:
> Hi Pankaj,
>
> I suspect you are trying to start Flink on a cluster with Flink 0.10.1
> installed?
>
> On Sat, Feb 27, 2016 at 9:20 AM, Pankaj Kumar <pancsen...@gmail.com>
> wrote:
>
>> I am trying to integrate kafka and flink.
>> my pom file is where {flink.version} is 0.10.2
>>
>> <dependency>
>> <groupId>org.apache.flink</groupId>
>> <artifactId>flink-java</artifactId>
>> <version>${flink.version}</version>
>> </dependency>
>> <dependency>
>> <groupId>org.apache.flink</groupId>
>> <artifactId>flink-streaming-java</artifactId>
>> <version>${flink.version}</version>
>> </dependency>
>> <dependency>
>> <groupId>org.apache.flink</groupId>
>> <artifactId>flink-clients</artifactId>
>> <version>${flink.version}</version>
>> </dependency>
>> <dependency>
>> <groupId>com.fasterxml.jackson.core</groupId>
>> <artifactId>jackson-databind</artifactId>
>> <version>2.6.4</version>
>> </dependency>
>> <dependency>
>> <groupId>org.projectlombok</groupId>
>> <artifactId>lombok</artifactId>
>> <version>1.16.6</version>
>> <scope>provided</scope>
>> </dependency>
>> <dependency>
>> <groupId>org.springframework</groupId>
>> <artifactId>spring-web</artifactId>
>> <version>4.2.4.RELEASE</version>
>> </dependency>
>> <dependency>
>> <groupId>org.apache.flink</groupId>
>> <artifactId>flink-connector-kafka</artifactId>
>> <version>${flink.version}</version>
>> </dependency>
>>
>> when i am running my jar with flink command line using command
>>
>> bin/flink run ~/apache_flink/target/Application-0.0.1.jar
>>
>> I am getting error
>>
>> tatus of job d20986a31f2a8166986d7db354de0ff7 changed to FAILED.
>> java.lang.NoSuchMethodError:
>> org.apache.flink.streaming.api.operators.StreamingRuntimeContext.isCheckpointingEnabled()Z
>> at
>> org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer.run(FlinkKafkaConsumer.java:387)
>> at
>> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:58)
>> at
>> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:55)
>>
>>
>> I am building final jar using command *mvn clean package -Pbuild-jar*
>>
>>
>
