Shanthoosh Venkataraman created SAMZA-2710:
----------------------------------------------
Summary: Handle avro compatibility issues in samza-sql engine
Key: SAMZA-2710
URL: https://issues.apache.org/jira/browse/SAMZA-2710
Project: Samza
Issue Type: Improvement
Reporter: Shanthoosh Venkataraman
When we upgraded avro version to 1.9, we started to observe the following error
in Samza SQL engine.
{noformat}
java.lang.ClassCastException: com.linkedin.events.Guid cannot be cast to
org.apache.avro.generic.GenericData$Fixed
at
org.apache.samza.sql.avro.AvroRelConverter.convertToJavaObject(AvroRelConverter.java:269)
at
org.apache.samza.sql.avro.AvroRelConverter.lambda$convertToRelRecord$2(AvroRelConverter.java:137)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1374)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
at
org.apache.samza.sql.avro.AvroRelConverter.convertToRelRecord(AvroRelConverter.java:139)
at
org.apache.samza.sql.avro.AvroRelConverter.convertToJavaObject(AvroRelConverter.java:234)
at
org.apache.samza.sql.udfs.CreateKafkaEventHeaderUdf.execute(CreateKafkaEventHeaderUdf.java:33){noformat}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
