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

commit 3b7a351a645e04a1bd6f717b944c5d985b4f7626
Author: Peeyush Gupta <peeyush.gu...@couchbase.com>
AuthorDate: Tue Jun 24 14:51:31 2025 -0700

    [NO ISSUE][EXT] Query fails on GCS external delta table
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Ext-ref: MB-67321
    Change-Id: Ibd700a0c4e740139630869d98ce7cf52389ea5cf
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19984
    Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Reviewed-by: Hussain Towaileb <hussai...@gmail.com>
    Reviewed-by: Peeyush Gupta <peeyush.gu...@couchbase.com>
    Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
---
 .../external/input/record/reader/aws/delta/DeltaReaderFactory.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/delta/DeltaReaderFactory.java
 
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/delta/DeltaReaderFactory.java
index 10a527e641..8328ec323c 100644
--- 
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/delta/DeltaReaderFactory.java
+++ 
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/delta/DeltaReaderFactory.java
@@ -100,6 +100,7 @@ public abstract class DeltaReaderFactory implements 
IRecordReaderFactory<Object>
             throws AlgebricksException, HyracksDataException {
         JobConf conf = new JobConf();
         ICcApplicationContext appCtx = (ICcApplicationContext) 
serviceCtx.getApplicationContext();
+        locationConstraints = getPartitions(appCtx);
         configureJobConf(appCtx, conf, configuration);
         confFactory = new ConfFactory(conf);
         String tableMetadataPath = getTablePath(configuration);
@@ -156,7 +157,6 @@ public abstract class DeltaReaderFactory implements 
IRecordReaderFactory<Object>
             scanFiles = getScanFiles(scan, engine);
         }
         LOGGER.info("Number of delta table parquet data files to scan: {}", 
scanFiles.size());
-        locationConstraints = getPartitions(appCtx);
         configuration.put(ExternalDataConstants.KEY_PARSER, 
ExternalDataConstants.FORMAT_DELTA);
         distributeFiles(scanFiles, 
getPartitionConstraint().getLocations().length);
         issueWarnings(warnings, warningCollector);

Reply via email to