Hi Kamil,
You need to use Types.LONG() for bigint type in Python DataStream API. See
[1] for more details.
Regards,
Dian
[1]
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/python/datastream/data_types/#supported-data-types
On Sun, Nov 28, 2021 at 11:26 PM Kamil ty wrote:
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 si
