flink tableEnv.toAppendStream报错 org.apache.flink.api.common.typeinfo.TypeInformation does not match

flink中将Table转为DataStream时报如下异常:

异常

Arity [6] of result [[Lorg.apache.flink.api.common.typeinfo.TypeInformation;@7e345bac] does not match the number[1] of requested type [GenericType].

解决办法

1.检查字段名是否和sql select出的列名一致
2.检查getter 和 setter
3.检查是否有无参构造函数。

flink tableEnv.toAppendStream报错 org.apache.flink.api.common.typeinfo.TypeInformation does not match

上一篇:Android 线程池ThreadPoolExecutor类


下一篇:coreldraw勾图的好技巧详解