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;
             }
 

Reply via email to