Hi,
I have just noticed that flink confluent avro will use legacy timestamp mapping 
<https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/connectors/table/formats/avro/#timestamp_mapping-legacy>,
 which results in
java.lang.UnsupportedOperationException: Unsupported to derive Schema for type: 
TIMESTAMP_LTZ(3)
at 
org.apache.flink.formats.avro.typeutils.AvroSchemaConverter.convertToSchema(AvroSchemaConverter.java:494)
 ~[flink-sql-avro-1.19.2.jar:1.19.2] 
however, this argument is only available for flink avro not flink confluent 
avro format. Therefore it is unable to cast unix timstamp in avro properly as a 
source table in Flink, while using confluent-avro format (where you can hook 
schema registry).
Is this a bug or have I missed something? 

Best,
Tiansu 

Reply via email to