@Jark Wuthanks reply. However Several case I want to cover: 1, Unknown types CITEXT: Flink SQL cannot exexute "CREATE TABLE string_table (pk SERIAL, vc VARCHAR(2), vcv CHARACTER VARYING(2), ch CHARACTER(4), c CHAR(3), t TEXT, b BYTEA, bnn BYTEA NOT NULL, ct CITEXT, PRIMARY KEY(pk));". this is because org.apache.flink.connector.jdbc.catalog.PostgresCatalog#fromJDBCType cannot support CITEXT.
2， TIMESTAMP_WITH_TIME_ZONE unsuppoted : org.apache.flink.table.runtime.typeutils.InternalSerializers#createInternal cannot support TIMESTAMP_WITH_TIME_ZONE. 3， Unsupported types(MySQL): org.apache.flink.connector.jdbc.dialect.MySQLDialect#unsupportedTypes provide the unsuppoted types. 4, Unsupported types(Postgres): org.apache.flink.connector.jdbc.dialect.PostgresDialect#unsupportedTypes provide the unsuppoted types. 5, (Postgres) parts of types implements referenced from Postgres https://www.postgresql.org/docs/12/datatype.html .6, (MySQL) parts of types implements referenced from MySQL https://dev.mysql.com/doc/refman/8.0/en/data-types.html. Please let me If you have any suggestion. ------------------------------------------------------------------ 发件人：Jark Wu <[email protected]> 发送时间：2021年6月23日(星期三) 23:13 收件人：dev <[email protected]>; 云华 <[email protected]> 主 题：Re: [DISCUSS] [FLINK-23122] Provide the Dynamic register converter 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, 云华 <[email protected]> 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
