Skip to content

Commit 32148a8

Browse files
committed
fix: correct type casting for GenericData.Array in convertMap method
1 parent a55d494 commit 32148a8

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/java/kafka/automq/table/binder/AvroValueAdapter.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,8 @@ protected List<?> convertList(Object sourceValue, Schema sourceSchema, Types.Lis
126126

127127
@Override
128128
protected Map<?, ?> convertMap(Object sourceValue, Schema sourceSchema, Types.MapType targetType) {
129-
if (sourceValue instanceof GenericData.Array<?> arrayValue) {
129+
if (sourceValue instanceof GenericData.Array) {
130+
GenericData.Array<?> arrayValue = (GenericData.Array<?>) sourceValue;
130131
// Handle map represented as an array of key-value records
131132
Map<Object, Object> recordMap = new HashMap<>();
132133
Schema kvSchema = sourceSchema.getElementType();

0 commit comments

Comments
 (0)