将 flink 从 1.10 升级到 1.11，遇到错误“找不到执行应用程序的 ExecutorFactory" [英] upgraded flink from 1.10 to 1.11, met error 'No ExecutorFactory found to execute the application'

问题描述

java.lang.IllegalStateException: No ExecutorFactory found to execute the application.
    at org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFactory(DefaultExecutorServiceLoader.java:84)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1803)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1713)
    at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:74)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1699)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1681)
    at com.cep.StaticAlarmGenerationEntryTest.main(StaticAlarmGenerationEntryTest.java:149)

我把FLink从1.10升级到1.11后遇到的错误，我的IDE是eclipse.我尝试添加 artifactId:flink-clients_${scala.binary.version}，但仍然失败.任何人已经遇到并解决了这个问题，请告诉我.非常感谢.

The error I met after I upgraded FLink from 1.10 to 1.11, and my IDE is eclipse. and I tried to add artifactId:flink-clients_${scala.binary.version}, but still failed. Anybody already met and solved this issue, pls tell me. thanks a lot.

推荐答案

参见 1.11 发行说明，您现在必须在其中添加对flink-clients.

See the 1.11 release note, where you now have to add an explicit dependency on flink-clients.

这篇关于将 flink 从 1.10 升级到 1.11，遇到错误“找不到执行应用程序的 ExecutorFactory"的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！