ink.version}/version
> >/dependency
> >
> >
> >原始邮件
> >发件人:Congxian qiuqcx978132...@gmail.com
> >收件人:user-zhuser...@flink.apache.org
> >抄送:Jark wuimj...@gmail.com; Jun zhangzhangjunemail...@gmail.com
> >发送时间:2020年7月7日(周二) 19:35
> >主题:Re: Re: Re:
t;/dependency
>
>
>原始邮件
>发件人:Congxian qiuqcx978132...@gmail.com
>收件人:user-zhuser...@flink.apache.org
>抄送:Jark wuimj...@gmail.com; Jun zhangzhangjunemail...@gmail.com
>发送时间:2020年7月7日(周二) 19:35
>主题:Re: Re: Re: Re: flink 1.11 作业执行异常
>
>
>Hi 从这个报错看上去是尝试通过 serviceLoader 加载
zhangzhangjunemail...@gmail.com
发送时间:2020年7月7日(周二) 19:35
主题:Re: Re: Re: Re: flink 1.11 作业执行异常
Hi 从这个报错看上去是尝试通过 serviceLoader 加载一些 factory 的时候出错了(找不到),可以看看对应的 module 的
resources 文件下是否有对应的 resource 文件 Best, Congxian sunfulin sunfulin0...@163.com
于2020年7月7日周二 下午6:29写道: hi, 我的pom文件本地执行时,scope的
Hi
从这个报错看上去是尝试通过 serviceLoader 加载一些 factory 的时候出错了(找不到),可以看看对应的 module 的
resources 文件下是否有对应的 resource 文件
Best,
Congxian
sunfulin 于2020年7月7日周二 下午6:29写道:
>
>
>
> hi,
> 我的pom文件本地执行时,scope的provided都是去掉的。
>
> org.apache.flink
>
> flink-table-planner-blink_${scala.binary.version}
>
hi,
我的pom文件本地执行时,scope的provided都是去掉的。
org.apache.flink
flink-table-planner-blink_${scala.binary.version}
${flink.version}
确实比较诡异。org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFactory(DefaultExecutorServiceLoader.java:84)
这个异常在啥情况下会触发到。
在
如果是在 IDEA 中运行的话,你看看 blink planner 这个依赖的 scope 是不是被 provided 掉了? 去掉 provided
再试试看?
Best,
Jark
On Tue, 7 Jul 2020 at 18:01, sunfulin wrote:
> hi,
> @Jun Zhang 我一直使用的就是blink planner,这个jar包一直都有的。
>
> @Jark Wu 我是在本地idea中直接运行的,还没有打包到集群跑。跟这个有关系么?
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-07-07
hi,
@Jun Zhang 我一直使用的就是blink planner,这个jar包一直都有的。
@Jark Wu 我是在本地idea中直接运行的,还没有打包到集群跑。跟这个有关系么?
在 2020-07-07 15:40:17,"Jark Wu" 写道:
>Hi,
>
>你是作业打包后在集群执行的,还是在 IDEA 中运行的呢?
>
>Best,
>Jark
>
>On Tue, 7 Jul 2020 at 15:31, Jun Zhang wrote:
>
>> hi.sunfulin
>>
Hi,
你是作业打包后在集群执行的,还是在 IDEA 中运行的呢?
Best,
Jark
On Tue, 7 Jul 2020 at 15:31, Jun Zhang wrote:
> hi.sunfulin
> 你有没有导入blink的planner呢,加入这个试试
>
>
> org.apache.flink
> flink-table-planner-blink_${scala.binary.version}
> ${flink.version}
>
>
>
> sunfulin 于2020年7月7日周二 下午3:21写道:
>
>>
>>
hi.sunfulin
你有没有导入blink的planner呢,加入这个试试
org.apache.flink
flink-table-planner-blink_${scala.binary.version}
${flink.version}
sunfulin 于2020年7月7日周二 下午3:21写道:
>
>
>
> hi, jark
> 我的执行代码其实很简单,就是下面的执行逻辑。不知道是不是我缺了什么依赖配置。我debug看了下异常执行,是说Flink
> configuration里的DeployOptions.TARGET
>
hi, jark
我的执行代码其实很简单,就是下面的执行逻辑。不知道是不是我缺了什么依赖配置。我debug看了下异常执行,是说Flink
configuration里的DeployOptions.TARGET (execution.target)没有匹配到配置?之前貌似从没有关注过这个配置。
//构建StreamExecutionEnvironment
public static final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
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
11 matches
Mail list logo