Hi, `TIMESTAMP_WITH_TIME_ZONE` is not supported in the Flink SQL engine, even though it is listed in the type API.
I think what you are looking for is the RawValueType which can be used as user-defined type. You can use `DataTypes.RAW(TypeInformation)` to define a Raw type with the given TypeInformation which includes the serializer and deserializer. Best, Jark On Wed, 23 Jun 2021 at 21:09, 云华 <yun...@dtstack.com> wrote: > > Hi everyone, > I want to rework type conversion system in connector and flink table > module to be resuable and scalability. > I Postgres system, the type '_citext' will not supported in > org.apache.flink.connector.jdbc.catalog.PostgresCatalog#fromJDBCType. > what's more, > org.apache.flink.table.runtime.typeutils.InternalSerializers#createInternal > cannnot support the TIMESTAMP_WITH_TIME_ZONE. > For more background and api design : > https://issues.apache.org/jira/browse/FLINK-23122. > Please let me know if this matches your thoughts. > > > > Regards,Jack
