You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by sh...@apache.org on 2021/11/23 21:56:29 UTC
[samza] branch master updated: Update AvroRelConverter.java (#1562)
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 <he...@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());