danny0405 commented on code in PR #11727:
URL: https://github.com/apache/hudi/pull/11727#discussion_r1779312862
##########
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java:
##########
@@ -282,12 +286,23 @@ private static ColumnVector createVectorFromConstant(
}
return tv;
case ARRAY:
- HeapArrayVector arrayVector = new HeapArrayVector(batchSize);
- if (value == null) {
- arrayVector.fillWithNulls();
- return arrayVector;
+ ArrayType arrayType = (ArrayType) type;
+ if (arrayType.getElementType().isAnyOf(LogicalTypeFamily.CONSTRUCTED))
{
+ HeapArrayGroupColumnVector arrayGroup = new
HeapArrayGroupColumnVector(batchSize);
+ if (value == null) {
+ arrayGroup.fillWithNulls();
+ return arrayGroup;
+ } else {
+ throw new UnsupportedOperationException("Unsupported create row
with default value.");
Review Comment:
do you mean create array with defaults?
--
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]
