Hello I'm trying to convert a datastream into a table using: table_env.from_datastream(ds)
The ds contains some fields with the Types.BIG_INT() type. Those fields
seem to be converted to: RAW('java.math.BigInteger', '...'). This is seen
as an error by flink which is resulting in table query and sink schema
mismatch (incompatible types) (BIGINT in the sink schema and
RAW('java.math.BigInteger','...') in the query.)
Any help with this would be appreciated.
Best Regards
Kamil
