[samza] branch master updated: Update AvroRelConverter.java (#1562)

[shanthoosh]

This is an automated email from the ASF dual-hosted git repository.

shanthoosh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new d77211d  Update AvroRelConverter.java (#1562)
d77211d is described below

commit d77211dd5dbb4f18ba1e9504810dd6483bd70f8c
Author: Hengyu JiaNG <hengyu...@gmail.com>
AuthorDate: Tue Nov 23 13:56:21 2021 -0800

    Update AvroRelConverter.java (#1562)
    
    Update AvroRelConverter to fix an compatibility issue with avro 1.9.
---
 samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java 
b/samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
index b7cee00..706a87b 100644
--- a/samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
+++ b/samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
@@ -266,7 +266,7 @@ public class AvroRelConverter implements SamzaRelConverter {
       case ENUM:
         return avroObj.toString();
       case FIXED:
-        GenericData.Fixed fixed = (GenericData.Fixed) avroObj;
+        org.apache.avro.generic.GenericFixed fixed = 
(org.apache.avro.generic.GenericFixed) avroObj;
         return new ByteString(fixed.bytes());
       case BYTES:
         return new ByteString(((ByteBuffer) avroObj).array());