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. Let me know what i should do to fix. Thanks, Prasanna. |
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? Prasanna kumar <[hidden email]> 于2020年5月24日周日 下午8:04写道:
|
In reply to this post by Prasanna kumar
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 Best, Guowei Prasanna kumar <[hidden email]> 于2020年5月24日周日 下午8:04写道:
|
In reply to this post by Prasanna kumar
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? Best, Guowei Prasanna kumar <[hidden email]> 于2020年5月24日周日 下午8:04写道:
|
In reply to this post by Prasanna kumar
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 |
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). Best, tison. Guowei Ma <[hidden email]> 于2020年5月25日周一 上午10:49写道: Hi |
In reply to this post by Prasanna kumar
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:
|
In reply to this post by Prasanna kumar
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 . |
Free forum by Nabble | Edit this page |