当前位置:网站首页>【flink】报错整理 Could not instantiate the executor. Make sure a planner module is on the classpath
【flink】报错整理 Could not instantiate the executor. Make sure a planner module is on the classpath
2022-07-30 19:17:00 【kiraraLou】
前言
Flink 版本 1.15.1
scala 版本 2.12
最近在学习 Flink
, 在 IDEA
中调试 Flink sql
代码时报错,报错内容如下:
Exception in thread "main" org.apache.flink.table.api.TableException: Could not instantiate the executor. Make sure a planner module is on the classpath
at org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.lookupExecutor(AbstractStreamTableEnvironmentImpl.java:108)
at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.create(StreamTableEnvironmentImpl.java:100)
at org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamTableEnvironment.java:122)
at org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamTableEnvironment.java:94)
at table.FlinkTableTest.main(FlinkTableTest.java:15)
Caused by: org.apache.flink.table.api.ValidationException: Multiple factories for identifier 'default' that implement 'org.apache.flink.table.delegation.ExecutorFactory' found in the classpath.
Ambiguous factory classes are:
org.apache.flink.table.planner.delegation.DefaultExecutorFactory
org.apache.flink.table.planner.loader.DelegateExecutorFactory
at org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:553)
at org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.lookupExecutor(AbstractStreamTableEnvironmentImpl.java:105)
... 4 more
Process finished with exit code 1
POM 文件
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner_2.12</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-loader</artifactId>
<version>${flink.version}</version>
</dependency>
问题原因
我们项目pom.xml
文件里面配置了两个解析器,这两个解析器不能同时并存,这里我们去掉 flink-table-planner_2.12
这个即可。
从 Flink 1.15 开始,发行版包含两个规划器:
flink-table-planner_2.12-1.15.1.jar
, in /opt, 包含查询规划器flink-table-planner-loader-1.15.1.jar
,默认加载/lib,包含隐藏在隔离类路径后面的查询计划器
注意: 两个规划器不能同时存在于类路径中。如果将它们都加载到/lib表作业中,则会失败。
问题解决!
参考:https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/configuration/advanced/
边栏推荐
- Entering the applet for the first time
- 第一次进入小程序判断
- Critical Reviews | A review of the global distribution of antibiotics and resistance genes in farmland soil by Nannong Zou Jianwen's group
- ResNet18-实现图像分类
- MindSpore:ImageFolderDataset数据读取问题
- VBA 运行时错误‘-2147217900(80040e14):自动化(Automation)错误
- 荐号 | 对你有恩的人,不要请吃饭来报答
- 中集世联达飞瞳全球工业人工智能AI领军者,全球顶尖AI核心技术高泛化性高鲁棒性稀疏样本持续学习,工业级高性能成熟AI产品规模应用
- Scrapy framework is introduced
- Delay queue optimization (2)
猜你喜欢
运营 23 年,昔日“国内第一大电商网站”黄了...
VBA 连接Access数据库和Excle
Does the satellite phone communicate directly with the satellite or through a ground station?
【Swords Offer】Swords Offer 17. Print n digits from 1 to the largest
VBA 运行时错误‘-2147217900(80040e14):自动化(Automation)错误
MindSpore:【MindSpore1.1】Mindspore安装后验证出现cudaSetDevice failed错误
Spark学习:用spark实现ETL
NXP IMX8QXP更换DDR型号操作流程
The Meta metaverse division lost 2.8 billion in the second quarter!Still want to keep betting?Metaverse development has yet to see a way out!
牛客刷题系列之进阶版(搜索旋转排序数组,链表内指定区间反转)
随机推荐
6块钱1斤,日本公司为何来中国收烟头?
OneFlow source code analysis: Op, Kernel and interpreter
浅聊对比学习(Contrastive Learning)第一弹
已删除
第十七届“振兴杯”全国青年 职业技能大赛——计算机程序设计员(云计算平台与运维)参赛回顾与总结
MYSQL(基本篇)——一篇文章带你走进MYSQL的奇妙世界
Chapter 14 Type Information
【MindSpore1.2.0-rc1产品】num_workers问题
The advanced version of the Niu Ke brushing series (team competition, sorting subsequences, inverting strings, deleting common characters, repairing pastures)
还有三天忙完
NXP IMX8QXP更换DDR型号操作流程
又一家公司面试的内容
Spark学习:用spark实现ETL
【Prometheus】Prometheus联邦的一次优化记录[续]
What is a RESTful API?
C# wpf borderless window add shadow effect
MindSpore: CV.Rescale(rescale,shift)中参数rescale和shift的含义?
How do radio waves transmit information?
7.30模拟赛总结
- daily a LeetCode 】 【 191. A number of 1