[jira] [Created] (BEAM-12385) AvroUtils exception when converting JDBC Row to GenericRecord

["Anant Damle (Jira)" <ji...@apache.org>]

Anant Damle created BEAM-12385:
----------------------------------

             Summary: AvroUtils exception when converting JDBC Row to GenericRecord
                 Key: BEAM-12385
                 URL: https://issues.apache.org/jira/browse/BEAM-12385
             Project: Beam
          Issue Type: Bug
          Components: sdk-java-core
            Reporter: Anant Damle


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

 
{code:java}
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());
        }));
{code}
 

 

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



--
This message was sent by Atlassian Jira
(v8.3.4#803005)