Hi everyone,

We are trying out flink 1.13.1 with kafka topics as avro backend but we are 
facing an issue while creating Table SQL that avro doesn't support precision 
greater than 3. I am not getting the reason why flink isn't supporting 
timestamps greater than 3 (exception 
<https://github.com/apache/flink/blob/3555741a12ba9fb65e8db9f731a131ab39d1cfe8/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java#L359>)
 as avro(1.10.0) does support microseconds precision.
Our kafka records contain a timestamp as YYYY-MM-DD'T'HH-mm-ss.SSSSSS'Z'. 
Eventually I have read the records as a custom UDF which drops seconds offset 
but wanted to know if there is a better way to handle this also the reason why 
isn't it's supported. It would be a great help for us to know about it and we 
can build on that.

Regards
Akshay Agarwal
-- 
 <https://grofers.com>

Reply via email to