将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.

推荐答案

请参见

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屋！