Skip to content

Commit

Permalink
[BugFix] Fix an exception when reading a Paimon table with array<row>…
Browse files Browse the repository at this point in the history
… column (backport #52743) (#52876)

Co-authored-by: Jiao Mingye <35512473+mxdzs0612@users.noreply.github.com>
  • Loading branch information
mergify[bot] and mxdzs0612 authored Nov 15, 2024
1 parent 6fea1e9 commit 36fc071
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@
import org.apache.paimon.data.Decimal;
import org.apache.paimon.data.InternalArray;
import org.apache.paimon.data.InternalMap;
import org.apache.paimon.data.InternalRow;
import org.apache.paimon.data.Timestamp;
import org.apache.paimon.data.columnar.ColumnarRow;
import org.apache.paimon.types.ArrayType;
import org.apache.paimon.types.DataField;
import org.apache.paimon.types.DataType;
Expand Down Expand Up @@ -110,7 +110,7 @@ public void unpackMap(List<ColumnValue> keys, List<ColumnValue> values) {

@Override
public void unpackStruct(List<Integer> structFieldIndex, List<ColumnValue> values) {
ColumnarRow array = (ColumnarRow) fieldData;
InternalRow array = (InternalRow) fieldData;
List<DataField> fields = ((RowType) dataType).getFields();
for (int i = 0; i < structFieldIndex.size(); i++) {
Integer idx = structFieldIndex.get(i);
Expand Down

0 comments on commit 36fc071

Please sign in to comment.