Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSourceFactory‘
启动FLINK SQL Client的时候
$FLINK_HOME/bin/sql-client.sh embedded -d $FLINK_HOME/conf/sql.my.yaml -l /home/appleyuchi/bigdata/flink-1.12/lib
出现下面的报错:
Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)
Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could not create execution context.
at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:818)
at org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException:
Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in
the classpath.
Reason: Required context properties mismatch.
The matching candidates:
org.apache.flink.table.sources.CsvAppendTableSourceFactory
Mismatched properties:
'connector.type' expects 'filesystem', but is 'kafka'
'format.type' expects 'csv', but is 'json'
最后两句啥意思:
| 报错信息 | sql.my.yaml中具体位置 |
|
'connector.type' expects 'filesystem', but is 'kafka' |
|
| 'format.type' expects 'csv', but is 'json' |
|
解决方案[1]:
$FLINK_HOME/conf/sql.my.yaml中的kafka版本修改为universal
Reference:
[1]Flink编程报错集锦
Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSourceFactory‘相关推荐
- Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSinkFactory‘
報錯如下: Exception in thread "main" org.apache.flink.table.api.TableException: findAndCreateT ...
- 报错：Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSourceFactory
重要错误提示: Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suit ...
- Could not find a suitable table factory for ‘org.apache.flink.table.factories.CatalogFactory‘
(Python3.6) appleyuchi@Desktop:~/bigdata/flink-1.12$ $FLINK_HOME/bin/sql-client.sh embedded -d $FLIN ...
- java.lang.String cannot be cast to org.apache.flink.table.data.StringData
完整报错: 16:54:56,851 INFO org.apache.hadoop.conf.Configuration.deprecation - io.bytes.per.checksum is ...
- java.lang.NoSuchMethodError: org.apache.flink.table.api.TableColumn.isGenerated()Z
完整报错如下: select * from dim_behavior; [ERROR] Could not execute SQL statement. Reason: java.lang.NoSuc ...
- org.apache.flink.table.catalog.exceptions.CatalogException: Failed to create Hive Metastore client
复现: $FLINK_HOME/bin/sql-client.sh embedded -d $FLINK_HOME/conf/flink-hive.yaml 完整报错如下: Exception in ...
- Cannot resolve method ‘call(java.lang.String, org.apache.flink.table.api.ApiExpression)‘
intellij提示: Cannot resolve method 'call(java.lang.String, org.apache.flink.table.api.ApiExpression)' ...
- org.apache.flink.table.api.bridge.java.internal.BatchTableEnvironmentImpl找不到的问题
Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.api.bridge.java.internal.BatchTa ...
- org.apache.flink.table.api.TableException: A raw type backed by type information has no serializable
DataStream<Order> result = tableEnv.toAppendStream(table, Order.class); 出现这个问题是因为Order类是嵌套内部类, ...
最新文章
- CCBPM高级开发之类设计与数据库设计命名规则
- RSA大会播报 – 2014最佳安全博客提名
- 牛客小白月赛5 E 面积 计算三角形面积模板 波尔约-格维也纳定理 匹克公式
- 关于Javascript Hijacking
- ### C++总结-[类成员函数]
- iScroll4下表单元素聚焦及键盘的异常问题
- 三星突然发布Galaxy S10 Lite和Note 10 Lite：有不同也有所同
- python编程技巧1002python编程技巧_总结Python编程中三条常用的技巧
- c语言清除命令行当前行_零基础学习树莓派_常用命令
- linux下各种player不显示mkv字幕的解决
- qq邮箱发送邮件服务器类型,设置QQ邮箱为发送邮件服务器的详细带图步骤
- 加权平均数的例子_加权平均数怎么算？举个具体的例子
- 10-Little prince's trip to Java-奇数魔方阵
- linux中怎样隐藏文件,Linux下如何隐藏文件
- 2021年茶艺师（初级）考试资料及茶艺师（初级）找解析
- Camunda 动态增加会签
- linux学习shell基础
- 水仙花数素数质因数分解的C语言实现
- Java集合与泛型学习笔记
- 【ZZULIOJ】1088: 手机短号 （多实例）
热门文章
- 高性能流媒体服务器EasyDSS前端重构(二) webpack + vue + AdminLTE 多页面提取共用文件, 优化编译时间...
- MFC动态调用DLL
- 原创：微信小程序源码解说：石头剪刀布（附源码下载）
- C#中实现鼠标拖动窗体的方法
- 转载：磁盘分区，一篇很好的文章
- 用户 'sa' 登录失败。原因: 未与信任 SQL Server 连接相关联
- Elementui select 设置点击事件，在Change事件前触发
- mysql与oracle性能对比,Oracle与MySQl对比，
- mysql text查找性能_MySQL TEXT字段性能
- hive mysql编码问题_Hive中文乱码 生产环境问题解决