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 <guowei....@gmail.com> 于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 >
