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)
