Re:Re: flink 1.11 作业执行异常

Tue, 07 Jul 2020 00:22:33 -0700 


hi, jark
我的执行代码其实很简单，就是下面的执行逻辑。不知道是不是我缺了什么依赖配置。我debug看了下异常执行，是说Flink 
configuration里的DeployOptions.TARGET （execution.target）没有匹配到配置？之前貌似从没有关注过这个配置。


//构建StreamExecutionEnvironment
public static final StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();

//构建EnvironmentSettings 并指定Blink Planner
private static final EnvironmentSettings bsSettings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();

//构建StreamTableEnvironment
public static final StreamTableEnvironment tEnv = 
StreamTableEnvironment.create(env, bsSettings);





       tEnv.executeSql(“ddl sql”);




        //source注册成表

        tEnv.createTemporaryView("test", ds, $("f0").as("id"), 
$("f1").as("first"), $("p").proctime());




        //join语句

        Table table = tEnv.sqlQuery("select b.* from test a left join my_dim 
FOR SYSTEM_TIME AS OF a.p AS b on a.first = b.userId");




        //输出

        tEnv.toAppendStream(table, Row.class).print("LookUpJoinJob");




        env.execute("LookUpJoinJob");








在 2020-07-06 14:59:17，"Jark Wu" <[email protected]> 写道：
>能分享下复现的作业代码不？
>
>Best,
>Jark
>
>On Mon, 6 Jul 2020 at 11:00, sunfulin <[email protected]> wrote:
>
>> Hi，
>> 我使用目前最新的Flink 1.11 rc4来测试我的作业。报了如下异常：
>> org.apache.flink.table.api.TableExecution: Failed to execute sql
>>
>>
>> caused by : java.lang.IlleagalStateException: No ExecutorFactory found to
>> execute the application.
>>   at
>> org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFactory(DefaultExecutorServiceLoader.java:84)
>>
>>
>> 想请教下这个异常是啥原因？我使用1.10.1跑同样的逻辑，是没有异常的。






















					回复