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 .
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 于2020年5月25日周一 上午10:49写道：
> Hi
> 1. You could check whether the 'o
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.h
