>From Murtadha Hubail <[email protected]>:
Murtadha Hubail has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20273 )
Change subject: [NO ISSUE][STO] Delete masked files before reading resource
files
......................................................................
[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.
Ex-ref: MB-68162
Change-Id: I58efaab43421dcb88d3341fd6cd7428104a8c70e
---
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/app/nc/task/LocalStorageCleanupTask.java
1 file changed, 20 insertions(+), 1 deletion(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/73/20273/1
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 435419b..61a07d1 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 @@
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();
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20273
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: ionic
Gerrit-Change-Id: I58efaab43421dcb88d3341fd6cd7428104a8c70e
Gerrit-Change-Number: 20273
Gerrit-PatchSet: 1
Gerrit-Owner: Murtadha Hubail <[email protected]>
Gerrit-MessageType: newchange
