The following exceptions are reported when converting a table into a datastream in Flink:

abnormal

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

Solution:

1. Check whether the field name is consistent with the column name in SQL SELECT

2. Check getter and setter

3. Check whether there is a parameter constructor.