search

DTStack / flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法
Apache License 2.0
2.02k stars 923 forks source link

Create table 中Array<String> 类型提交报错 #421

Open naichunW opened 3 years ago

naichunW commented 3 years ago

Field types of query result and redistered TabledSink do not match Query schema: [a: ARRAY] Sink schema: [a: LEGACY('ARRAY','ANY<[Ljava.lang.String;, ***')]

a49a commented 3 years ago

1.12 已经发布在FlinkX 项目里，没有这个问题

a49a commented 3 years ago

你可以把你全的SQL发下