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 fc7842ec1f0624dc09ab5c656c674e5c3be1248d Author: Murtadha Hubail <[email protected]> AuthorDate: Tue Aug 26 11:03:50 2025 +0300 [NO ISSUE][STO] Delete masked files before reading resource files - user model changes: no - storage format changes: no - interface changes: no Details: - During local storage clean up, delete masked (incomplete) files before trying to access any resource files to avoid reading corrupted data. Ext-ref: MB-68162 Change-Id: I58efaab43421dcb88d3341fd6cd7428104a8c70e Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20273 Integration-Tests: Murtadha Hubail <[email protected]> Tested-by: Murtadha Hubail <[email protected]> Reviewed-by: Murtadha Hubail <[email protected]> Reviewed-by: Michael Blow <[email protected]> --- .../java/org/apache/asterix/app/nc/task/LocalStorageCleanupTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/task/LocalStorageCleanupTask.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/task/LocalStorageCleanupTask.java index 435419bc6a..61a07d15ab 100644 --- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/task/LocalStorageCleanupTask.java +++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/task/LocalStorageCleanupTask.java @@ -43,9 +43,9 @@ public class LocalStorageCleanupTask implements INCLifecycleTask { INcApplicationContext appContext = (INcApplicationContext) cs.getApplicationContext(); PersistentLocalResourceRepository localResourceRepository = (PersistentLocalResourceRepository) appContext.getLocalResourceRepository(); + localResourceRepository.deleteCorruptedResources(); deleteInvalidMetadataIndexes(localResourceRepository); final Set<Integer> nodePartitions = appContext.getReplicaManager().getPartitions(); - localResourceRepository.deleteCorruptedResources(); INcApplicationContext appCtx = (INcApplicationContext) cs.getApplicationContext(); if (appCtx.isCloudDeployment() && nodePartitions.contains(metadataPartitionId)) { appCtx.getTransactionSubsystem().getTransactionManager().rollbackMetadataTransactionsWithoutWAL();
