Murtadha Hubail has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/3207
Change subject: [ASTERIXDB-2520[RT] Make Dataset Memory Reservation Idempotent
......................................................................
[ASTERIXDB-2520[RT] Make Dataset Memory Reservation Idempotent
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
- To account for multiple failures of metadata node, make
dataset memory reservation idempotent.
Change-Id: I360226187e176ce3a0ccdcd7a1b611a01d906394
---
M
asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetMemoryManager.java
1 file changed, 2 insertions(+), 1 deletion(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/07/3207/1
diff --git
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetMemoryManager.java
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetMemoryManager.java
index 1b4b48e..8aec240 100644
---
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetMemoryManager.java
+++
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetMemoryManager.java
@@ -82,7 +82,8 @@
@Override
public synchronized boolean reserve(int datasetId) {
if (reservedMap.containsKey(datasetId)) {
- throw new IllegalStateException("Memory is already reserved for
dataset: " + datasetId);
+ LOGGER.info("Memory is already reserved for dataset: {}", () ->
datasetId);
+ return true;
}
final long required = getTotalSize(datasetId);
if (!isAllocatable(required) && !allocatedMap.containsKey(datasetId)) {
--
To view, visit https://asterix-gerrit.ics.uci.edu/3207
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I360226187e176ce3a0ccdcd7a1b611a01d906394
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Murtadha Hubail <[email protected]>
