Hi,

你是作业打包后在集群执行的,还是在 IDEA 中运行的呢?

Best,
Jark

On Tue, 7 Jul 2020 at 15:31, Jun Zhang <[email protected]> wrote:

> hi.sunfulin
> 你有没有导入blink的planner呢,加入这个试试
>
> <dependency>
>     <groupId>org.apache.flink</groupId>
>     <artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
>     <version>${flink.version}</version>
> </dependency>
>
>
> sunfulin <[email protected]> 于2020年7月7日周二 下午3:21写道:
>
>>
>>
>>
>> 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跑同样的逻辑,是没有异常的。
>>
>

回复