Receiver class org.apache.flink.client.deployment.executors.LocalExecutor does not define or inherit an implementation of the resolved method 'abstract java.util.concurrent.CompletableFuture execute(org.apache.flink.api.dag.Pipeline, org.apache.flink.configuration.Configuration, java.lang.ClassLoader)' of interface org.apache.flink.core.execution.PipelineExecutor.
时间: 2023-09-02 13:10:13 浏览: 203
这个问题是由于 `LocalExecutor` 类没有实现 `PipelineExecutor` 接口的 `execute` 方法引起的。根据报错信息,`execute` 方法的签名应该是 `CompletableFuture execute(Pipeline, Configuration, ClassLoader)`。你可以检查一下 `LocalExecutor` 类是否正确实现了接口,并确保方法签名与接口定义一致。另外,你还可以查看一下 Flink 版本是否与你的代码兼容,可能需要更新或切换到适合的版本。
阅读全文