Table API 报一下异常: Field types of query result and registered TableSink
2020-07-04 11:22
2161 查看
报错信息如下:
Exception in thread “main” org.apache.flink.table.api.ValidationException: Field types of query result and
registered TableSink
default_catalog.
default_database.
demodo not match.
Query result schema: [id: String, aa: Long]
TableSink schema: [id: String, timestamp: Long, temperature: Double]
at org.apache.flink.table.sinks.TableSinkUtils.validateSink(TableSinkUtils.scala:64)atorg.apache.flink.table.planner.StreamPlanner.validateSink(TableSinkUtils.scala:64) at org.apache.flink.table.planner.StreamPlanner.validateSink(TableSinkUtils.scala:64)atorg.apache.flink.table.planner.StreamPlanner$anonfun2.apply(StreamPlanner.scala:146)atorg.apache.flink.table.planner.StreamPlanner2.apply(StreamPlanner.scala:146) at org.apache.flink.table.planner.StreamPlanner2.apply(StreamPlanner.scala:146)atorg.apache.flink.table.planner.StreamPlanner$anonfun$2.apply(StreamPlanner.scala:145)
at scala.Option.map(Option.scala:146)
原因:
查找的结果和要保存数据的结果不同
相关文章推荐
- asp.net core webapi 统一处理返回值、异常和请求参数验证
- 从Android document 中了解一下用API 杀死当前应用进程的问题
- 安卓异常总结---WARNING: Application does not specify an API level requirement!
- 8、Flink Table API & Flink Sql API
- iOS开发小技巧--利用苹果官方API播放视频(方法已经过时,了解一下)
- 一个Windows C++的线程类实现(封装API,形成一个类,但不完善。其实可以学习一下Delphi的TThread的写法)
- 简单记一下异常
- Call requires API level 4 (current min is 3):类似异常解决
- java应用中,调用第三方api如何处理异常(系统异常、操作异常等等)
- day05 API异常
- 讲一下Asp.net core MVC2.1 里面的 ApiControllerAttribute
- Java成神之路(十七)API、SPI与异常
- [系列] go-gin-api 路由中间件 - 捕获异常(四)
- lglib.table API
- HBase客户端API(整理 修改一下)
- Oracle Apps 11i Free Training : Table Registration API
- 异常:java.sql.SQLException: The total number of locks exceeds the lock table size
- C# 通过API获得屏幕某点的颜色(先转别人代码,有时间整理一下)
- navicat或者sqlyog连接mycat异常(1146 table xxx doesn,t exist)
- SQL异常处理-Mysql ERROR 1005 (HY000): Can't create table 'tmp' (errno: 13)