goutamadwant commented on code in PR #12305:
URL: https://github.com/apache/seatunnel/pull/12305#discussion_r4002299496
##########
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java:
##########
@@ -287,6 +288,9 @@ private int getArrayMapNotNullSize(Object v) {
int size = 0;
if (Objects.nonNull(v)) {
for (Map o : (Map[]) v) {
+ if (o == null) {
Review Comment:
Parquet's array-of-map reader returns `Object[]` (`convertListResult` uses
`result.toArray(new Object[0])`), and Iceberg list deserialization does the
same. Zeta calls typed `getBytesSize(rowType)` for every collected row, so
these normal `ARRAY<MAP<...>>` records fail at the preceding `(Map[]) v` cast
before this null guard. I reproduced the `ClassCastException` on this SHA using
the existing Parquet array-of-map fixture plus a size call. Please iterate over
`(Object[]) v` and cast each non-null element to `Map`; that also lets this
null handling cover those connector outputs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
