java.lang.NoSuchMethodError while writing to Kafka from Flink

[Prasanna kumar]

Hi Community , 

JAVA Version :1.8 

Flink Version : 1.9.1

I am facing issues while writing to kafka from flink running it locally in my laptop.   

I get the following error. 

 

Code Snippet.  

Serialization Schema Code.

The older FlinkKafkaProducer constructors are deprecated. 

This was the only link in the whole internet which mentions same problem as mine but the solution i have implemented but still the same issues.

https://stackoverflow.com/questions/58644549/how-to-implement-flinkkafkaproducer-serializer-for-kafka-2-2

Let me know what i should do to fix.

Thanks,

Prasanna.

[Guowei Ma]

Hi

1. You could check whether the 'org.apache.flink.api.java.clean' is in your classpath first. 

2. Do you follow the doc[1] to deploy your local cluster and run some existed examples such as WordCount?

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/deployment/cluster_setup.html

Prasanna kumar <[hidden email]> 于2020年5月24日周日 下午8:04写道：

Hi Community , 

JAVA Version :1.8 

Flink Version : 1.9.1

I am facing issues while writing to kafka from flink running it locally in my laptop.   

I get the following error. 

 

Code Snippet.  

Serialization Schema Code.

The older FlinkKafkaProducer constructors are deprecated. 

This was the only link in the whole internet which mentions same problem as mine but the solution i have implemented but still the same issues.

https://stackoverflow.com/questions/58644549/how-to-implement-flinkkafkaproducer-serializer-for-kafka-2-2

Let me know what i should do to fix.

Thanks,

Prasanna.

[Guowei Ma]

Hi

1. You could check whether the 'org.apache.flink.api.java.clean' is in your classpath first. 

2. Do you follow the doc[1] to deploy your local cluster and run some existed examples such as WordCount?

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/deployment/cluster_setup.html

Best,

Guowei

Prasanna kumar <[hidden email]> 于2020年5月24日周日 下午8:04写道：

Hi Community , 

JAVA Version :1.8 

Flink Version : 1.9.1

I am facing issues while writing to kafka from flink running it locally in my laptop.   

I get the following error. 

 

Code Snippet.  

Serialization Schema Code.

The older FlinkKafkaProducer constructors are deprecated. 

This was the only link in the whole internet which mentions same problem as mine but the solution i have implemented but still the same issues.

https://stackoverflow.com/questions/58644549/how-to-implement-flinkkafkaproducer-serializer-for-kafka-2-2

Let me know what i should do to fix.

Thanks,

Prasanna.

[Guowei Ma]

Hi

1. You could check whether the 'org.apache.flink.api.java.clean' is in your classpath first. 

2. Do you follow the doc[1] to deploy your local cluster and run some existed examples such as WordCount?

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/deployment/cluster_setup.html

Prasanna kumar <[hidden email]> 于2020年5月24日周日 下午8:04写道：

Hi Community , 

JAVA Version :1.8 

Flink Version : 1.9.1

I am facing issues while writing to kafka from flink running it locally in my laptop.   

I get the following error. 

 

Code Snippet.  

Serialization Schema Code.

The older FlinkKafkaProducer constructors are deprecated. 

This was the only link in the whole internet which mentions same problem as mine but the solution i have implemented but still the same issues.

https://stackoverflow.com/questions/58644549/how-to-implement-flinkkafkaproducer-serializer-for-kafka-2-2

Let me know what i should do to fix.

Thanks,

Prasanna.

[Guowei Ma]

Hi
1. You could check whether the 'org.apache.flink.api.java.clean' is in
your classpath first.
2. Do you follow the doc[1] to deploy your local cluster and run some
existed examples such as WordCount?

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/deployment/cluster_setup.html
Best,
Guowei

[tison]

Could you try to download binary dist from flink download page and re-execute the job? It seems like something wrong with flink-dist.jar.

BTW, please post user question on only user mailing list(not dev).

Guowei Ma <[hidden email]> 于2020年5月25日周一 上午10:49写道：

Hi
1. You could check whether the 'org.apache.flink.api.java.clean' is in
your classpath first.
2. Do you follow the doc[1] to deploy your local cluster and run some
existed examples such as WordCount?

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/deployment/cluster_setup.html
Best,
Guowei

[Chesnay Schepler]

Please double-check that your distribution and application jar were built against the same Flink version.

This looks related to a binary-compatibility issues reporter in FLINK-13586 .

On 24/05/2020 14:03, Prasanna kumar wrote:

Hi Community , 

JAVA Version :1.8 

Flink Version : 1.9.1

I am facing issues while writing to kafka from flink running it locally in my laptop.   

I get the following error. 

 

Code Snippet.  

Serialization Schema Code.

The older FlinkKafkaProducer constructors are deprecated. 

This was the only link in the whole internet which mentions same problem as mine but the solution i have implemented but still the same issues.

https://stackoverflow.com/questions/58644549/how-to-implement-flinkkafkaproducer-serializer-for-kafka-2-2

Let me know what i should do to fix.

Thanks,

Prasanna.

[Chesnay Schepler]

Please double-check that your distribution and application jar were
built against the same Flink version.

This looks related to a binary-compatibility issues reporter in
FLINK-13586 .