FlinkFlink SQL 报错 ClassCastException: VarCharType cannot be cast to RowType

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink SQL 报错 ClassCastException: VarCharType cannot be cast to RowType相关的知识,希望对你有一定的参考价值。

文章目录


1.概述

背景参考:【Flink】FLink SQL 如何使用嵌套格式的Schema

我想要实现通过flink table api来实现:

select * from Order order 
left join Store as store on 
order.store_id = store.id;  

这条

以上是关于FlinkFlink SQL 报错 ClassCastException: VarCharType cannot be cast to RowType的主要内容,如果未能解决你的问题,请参考以下文章

FlinkFlink 流API 和 Table 以及 SQL API是否可以共存

FlinkFlink SQL Cannot instantiate user function cannot assign instance LinkedMap FlinkKafkaConsum

FlinkFLink SQL TableException: Table sink doesn‘t support consuming update changes which is

FlinkFlink 报错 Writing records to streamload failed

FlinkFlink 写入 kafka 报错 Transactional Id authorization failed

FlinkFlink 做检查点 报错 Checkpoint Coordinator is suspending.