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