Ian Maxon has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/1729
Change subject: Metadata Count Temp Fix
......................................................................
Metadata Count Temp Fix
The Metadata dataverse doesn't quite fit into the transaction
model so some counters were being incremented but never decremented
on it, which disallowed soft checkpointing. This is a temporary
fix to this, but it is not addressing any of the consistency
issues, etc. It is simply to reallow soft checkpointing.
Change-Id: I3587e30e049a06a1536fe4e8ba131cd87fe832fe
---
M
asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
1 file changed, 5 insertions(+), 0 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/29/1729/1
diff --git
a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
index 2f30ff1..b75ef87 100644
---
a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
+++
b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
@@ -117,6 +117,7 @@
import org.apache.hyracks.storage.am.common.ophelpers.MultiComparator;
import org.apache.hyracks.storage.am.lsm.common.api.ILSMIndex;
import org.apache.hyracks.storage.am.lsm.common.api.ILSMIndexAccessor;
+import org.apache.hyracks.storage.am.lsm.common.api.LSMOperationType;
import org.apache.hyracks.storage.am.lsm.common.impls.AbstractLSMIndex;
public class MetadataNode implements IMetadataNode {
@@ -456,6 +457,8 @@
// TODO: fix exceptions once new BTree exception model is in
hyracks.
indexAccessor.forceInsert(tuple);
+
transactionSubsystem.getTransactionManager().getTransactionContext(jobId,false).decrementNumActiveOperations();
+ lsmIndex.getOperationTracker().completeOperation(lsmIndex,
LSMOperationType.FORCE_MODIFICATION,null,modCallback);
} finally {
datasetLifecycleManager.close(resourceName);
}
@@ -747,6 +750,8 @@
LSMIndexUtil.checkAndSetFirstLSN((AbstractLSMIndex) lsmIndex,
transactionSubsystem.getLogManager());
indexAccessor.forceDelete(tuple);
+
transactionSubsystem.getTransactionManager().getTransactionContext(jobId,false).decrementNumActiveOperations();
+ lsmIndex.getOperationTracker().completeOperation(lsmIndex,
LSMOperationType.FORCE_MODIFICATION,null,modCallback);
} finally {
datasetLifecycleManager.close(resourceName);
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/1729
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I3587e30e049a06a1536fe4e8ba131cd87fe832fe
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Ian Maxon <[email protected]>
Gerrit-Reviewer: Jenkins <[email protected]>
