Hi all, FLINK-12254[1] [2] updated TableSink and related interfaces to new type system which allows connectors use the new type system based on DataTypes.
But FLINK-12911 port UpsertStreamTableSink and RetractStreamTableSink to flink-api-java-bridge and returns TypeInformation of the requested record type which can't support types with precision and scale, e.g. TIMESTAMP(p), DECIMAL(p,s). /** * Returns the requested record type. */ TypeInformation<T> getRecordType(); A proposal is deprecating the *getRecordType* API and adding a *getRecordDataType* API instead to return the data type of the requested record. I have filed the issue FLINK-15469 and an initial PR to verify it. What do you think about this API changes? Any feedback are appreciated. [1] https://issues.apache.org/jira/browse/FLINK-12254 [2] https://github.com/apache/flink/pull/8596 [3] https://issues.apache.org/jira/browse/FLINK-15469 *Best Regards,* *Zhenghua Gao*
