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 <kamilt...@gmail.com> 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 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 >
