[BEAM-12385] AvroUtils exception when converting JDBC Row to GenericRecord

• Type: Bug
• Status: Triage Needed
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.32.0
• Component/s: sdk-java-core
• Assignee: Anant Damle
• Reporter: Anant Damle
• Created: 21/May/21 14:24
• Updated: 13/Apr/23 11:06
• Resolved: 07/Jun/21 20:21

Description

`AvroUtils.toAvroSchema()` and `AvroUtils.toGenericRecord()` throw exception for JDBC specific logical types like: `DATE`, `NVARCHAR`, `VARCHAR`, `LONGVARCHAR` etc.

 

pipeline
  .apply(JdbcIO.readRows()...)
  .apply(MapElements.via(
        (Row row) -> {
         // This statement throws Exception "Unhandled Logical Type"
          org.apache.avro.Schema schema = AvroUtils.toAvroSchema(row.getSchema());
        }));

 

 

This can be handled by adding additional case-statements in AvroUtils:

Issue Links

• links to: GitHub Pull Request #14858