yes versioning was issue . Job is working fine on flink 0.10.2.
On Mon, Feb 29, 2016 at 3:15 PM, Stephan Ewen <se...@apache.org> wrote:
> Hi!
>
> A "NoSuchMethodError" is always a sign of a version mixup. Please make
> sure both versions (cluster and client) are exactly the same.
>
> Stephan
>
>
> On Sat, Feb 27, 2016 at 11:05 AM, Pankaj Kumar <pancsen...@gmail.com>
> wrote:
>
>> 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*
>>>>
>>>>
>>>
>>
>
