This is an automated email from the ASF dual-hosted git repository.
mblow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git
The following commit(s) were added to refs/heads/master by this push:
new 3baa6b5529 [ASTERIXDB-3634][EXT] Fix reading nested dates in iceberg
3baa6b5529 is described below
commit 3baa6b5529750bb35c32e478f56de0c0e629cb2b
Author: Peeyush Gupta <[email protected]>
AuthorDate: Thu Dec 18 13:18:20 2025 -0800
[ASTERIXDB-3634][EXT] Fix reading nested dates in iceberg
Ext-ref: MB-63115
Change-Id: Ica47d09ebb3f4717cddbe8d6af893b901db44af8
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20686
Reviewed-by: Hussain Towaileb <[email protected]>
Tested-by: Jenkins <[email protected]>
Integration-Tests: Jenkins <[email protected]>
---
.../apache/asterix/external/parser/IcebergParquetDataParser.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/IcebergParquetDataParser.java
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/IcebergParquetDataParser.java
index 5afddc37b7..0fc9e359a0 100644
---
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/IcebergParquetDataParser.java
+++
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/parser/IcebergParquetDataParser.java
@@ -206,14 +206,14 @@ public class IcebergParquetDataParser extends
AbstractDataParser implements IRec
NestedField field = schema.fields().get(i);
String fieldName = field.name();
Type fieldType = field.type();
- ATypeTag typeTag =
- getTypeTag(fieldType, structLike.get(i,
fieldType.typeId().javaClass()) == null, parserContext);
+ Object sourceValue = structLike.get(i, Object.class);
+ ATypeTag typeTag = getTypeTag(fieldType, sourceValue == null,
parserContext);
IValueReference value;
if (valueEmbedder.shouldEmbed(fieldName, typeTag)) {
value = valueEmbedder.getEmbeddedValue();
} else {
valueBuffer.reset();
- parseValue(fieldType, structLike.get(i,
fieldType.typeId().javaClass()), valueBuffer.getDataOutput());
+ parseValue(fieldType, sourceValue,
valueBuffer.getDataOutput());
value = valueBuffer;
}