You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by sunfulin <su...@163.com> on 2020/07/06 03:00:07 UTC
flink 1.11 作业执行异常
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跑同样的逻辑，是没有异常的。
Re: Re: Re: Re: flink 1.11 作业执行异常
Posted by Congxian Qiu <qc...@gmail.com>.
Hi
从这个报错看上去是尝试通过 serviceLoader 加载一些 factory 的时候出错了（找不到），可以看看对应的 module 的
resources 文件下是否有对应的 resource 文件
Best,
Congxian
sunfulin <su...@163.com> 于2020年7月7日周二 下午6:29写道：
>
>
>
> hi,
> 我的pom文件本地执行时，scope的provided都是去掉的。
> <dependency>
> <groupId>org.apache.flink</groupId>
>
> <artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
> <version>${flink.version}</version>
> </dependency>
>
>
> 确实比较诡异。org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFactory(DefaultExecutorServiceLoader.java:84)
> 这个异常在啥情况下会触发到。
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-07-07 18:10:58，"Jark Wu" <im...@gmail.com> 写道：
> >如果是在 IDEA 中运行的话，你看看 blink planner 这个依赖的 scope 是不是被 provided 掉了？ 去掉
> provided
> >再试试看？
> >
> >Best,
> >Jark
> >
> >On Tue, 7 Jul 2020 at 18:01, sunfulin <su...@163.com> wrote:
> >
> >> hi,
> >> @Jun Zhang 我一直使用的就是blink planner，这个jar包一直都有的。
> >>
> >> @Jark Wu 我是在本地idea中直接运行的，还没有打包到集群跑。跟这个有关系么？
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >> 在 2020-07-07 15:40:17，"Jark Wu" <im...@gmail.com> 写道：
> >> >Hi,
> >> >
> >> >你是作业打包后在集群执行的，还是在 IDEA 中运行的呢？
> >> >
> >> >Best,
> >> >Jark
> >> >
> >> >On Tue, 7 Jul 2020 at 15:31, Jun Zhang <zh...@gmail.com>
> >> 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 <su...@163.com> 于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" <im...@gmail.com> 写道：
> >> >>> >能分享下复现的作业代码不？
> >> >>> >
> >> >>> >Best,
> >> >>> >Jark
> >> >>> >
> >> >>> >On Mon, 6 Jul 2020 at 11:00, sunfulin <su...@163.com>
> 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跑同样的逻辑，是没有异常的。
> >> >>>
> >> >>
> >>
>
Re:Re: Re: Re: flink 1.11 作业执行异常
Posted by sunfulin <su...@163.com>.
hi,
我的pom文件本地执行时，scope的provided都是去掉的。
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
确实比较诡异。org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFactory(DefaultExecutorServiceLoader.java:84) 这个异常在啥情况下会触发到。
在 2020-07-07 18:10:58，"Jark Wu" <im...@gmail.com> 写道：
>如果是在 IDEA 中运行的话，你看看 blink planner 这个依赖的 scope 是不是被 provided 掉了？ 去掉 provided
>再试试看？
>
>Best,
>Jark
>
>On Tue, 7 Jul 2020 at 18:01, sunfulin <su...@163.com> wrote:
>
>> hi,
>> @Jun Zhang 我一直使用的就是blink planner，这个jar包一直都有的。
>>
>> @Jark Wu 我是在本地idea中直接运行的，还没有打包到集群跑。跟这个有关系么？
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> 在 2020-07-07 15:40:17，"Jark Wu" <im...@gmail.com> 写道：
>> >Hi,
>> >
>> >你是作业打包后在集群执行的，还是在 IDEA 中运行的呢？
>> >
>> >Best,
>> >Jark
>> >
>> >On Tue, 7 Jul 2020 at 15:31, Jun Zhang <zh...@gmail.com>
>> 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 <su...@163.com> 于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" <im...@gmail.com> 写道：
>> >>> >能分享下复现的作业代码不？
>> >>> >
>> >>> >Best,
>> >>> >Jark
>> >>> >
>> >>> >On Mon, 6 Jul 2020 at 11:00, sunfulin <su...@163.com> 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跑同样的逻辑，是没有异常的。
>> >>>
>> >>
>>
Re: Re: Re: flink 1.11 作业执行异常
Posted by Jark Wu <im...@gmail.com>.
如果是在 IDEA 中运行的话，你看看 blink planner 这个依赖的 scope 是不是被 provided 掉了？ 去掉 provided
再试试看？
Best,
Jark
On Tue, 7 Jul 2020 at 18:01, sunfulin <su...@163.com> wrote:
> hi,
> @Jun Zhang 我一直使用的就是blink planner，这个jar包一直都有的。
>
> @Jark Wu 我是在本地idea中直接运行的，还没有打包到集群跑。跟这个有关系么？
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-07-07 15:40:17，"Jark Wu" <im...@gmail.com> 写道：
> >Hi,
> >
> >你是作业打包后在集群执行的，还是在 IDEA 中运行的呢？
> >
> >Best,
> >Jark
> >
> >On Tue, 7 Jul 2020 at 15:31, Jun Zhang <zh...@gmail.com>
> 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 <su...@163.com> 于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" <im...@gmail.com> 写道：
> >>> >能分享下复现的作业代码不？
> >>> >
> >>> >Best,
> >>> >Jark
> >>> >
> >>> >On Mon, 6 Jul 2020 at 11:00, sunfulin <su...@163.com> 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跑同样的逻辑，是没有异常的。
> >>>
> >>
>
Re:Re: Re: flink 1.11 作业执行异常
Posted by sunfulin <su...@163.com>.
hi,
@Jun Zhang 我一直使用的就是blink planner，这个jar包一直都有的。
@Jark Wu 我是在本地idea中直接运行的，还没有打包到集群跑。跟这个有关系么？
在 2020-07-07 15:40:17，"Jark Wu" <im...@gmail.com> 写道：
>Hi,
>
>你是作业打包后在集群执行的，还是在 IDEA 中运行的呢？
>
>Best,
>Jark
>
>On Tue, 7 Jul 2020 at 15:31, Jun Zhang <zh...@gmail.com> 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 <su...@163.com> 于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" <im...@gmail.com> 写道：
>>> >能分享下复现的作业代码不？
>>> >
>>> >Best,
>>> >Jark
>>> >
>>> >On Mon, 6 Jul 2020 at 11:00, sunfulin <su...@163.com> 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跑同样的逻辑，是没有异常的。
>>>
>>
Re: Re: flink 1.11 作业执行异常
Posted by Jark Wu <im...@gmail.com>.
Hi,
你是作业打包后在集群执行的，还是在 IDEA 中运行的呢？
Best,
Jark
On Tue, 7 Jul 2020 at 15:31, Jun Zhang <zh...@gmail.com> 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 <su...@163.com> 于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" <im...@gmail.com> 写道：
>> >能分享下复现的作业代码不？
>> >
>> >Best,
>> >Jark
>> >
>> >On Mon, 6 Jul 2020 at 11:00, sunfulin <su...@163.com> 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跑同样的逻辑，是没有异常的。
>>
>
Re: Re: flink 1.11 作业执行异常
Posted by Jun Zhang <zh...@gmail.com>.
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 <su...@163.com> 于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" <im...@gmail.com> 写道：
> >能分享下复现的作业代码不？
> >
> >Best,
> >Jark
> >
> >On Mon, 6 Jul 2020 at 11:00, sunfulin <su...@163.com> 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跑同样的逻辑，是没有异常的。
>
Re:Re: flink 1.11 作业执行异常
Posted by sunfulin <su...@163.com>.
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" <im...@gmail.com> 写道：
>能分享下复现的作业代码不？
>
>Best,
>Jark
>
>On Mon, 6 Jul 2020 at 11:00, sunfulin <su...@163.com> 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跑同样的逻辑，是没有异常的。
Re: flink 1.11 作业执行异常
Posted by Jark Wu <im...@gmail.com>.
能分享下复现的作业代码不？
Best,
Jark
On Mon, 6 Jul 2020 at 11:00, sunfulin <su...@163.com> 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跑同样的逻辑，是没有异常的。