>From Peeyush Gupta <[email protected]>:
Peeyush Gupta has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20649?usp=email )
Change subject: [ASTERIXDB-3678][TX] Failure committing a metadata transaction
......................................................................
[ASTERIXDB-3678][TX] Failure committing a metadata transaction
- user model changes: no
- storage format changes: no
- interface changes: no
Ext-ref: MB-69729
Change-Id: I63be765a330bb15d53dfaa0ef1c8679355396628
---
M
asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/SizeBoundedConcurrentMergePolicy.java
1 file changed, 4 insertions(+), 2 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/49/20649/1
diff --git
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/SizeBoundedConcurrentMergePolicy.java
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/SizeBoundedConcurrentMergePolicy.java
index 78fbf99..3f7a5c4 100644
---
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/SizeBoundedConcurrentMergePolicy.java
+++
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/SizeBoundedConcurrentMergePolicy.java
@@ -20,6 +20,7 @@
import static
org.apache.asterix.common.storage.SizeBoundedConcurrentMergePolicy.Range.isRangeMergable;
+import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@@ -134,13 +135,14 @@
* but in case the components in the range does not contribute enough to
exceed maxComponentSize then the candidate
* range will be [leftBoundary, endComponentIndex] which satisfies both 1
& 2.
*</p>
- * @param diskComponents The disk components within an Index
+ * @param inputDiskComponents The disk components within an Index
* @param localMinMergeComponentCount The min count of contiguous
components required to call a mergable range.
* @param countFlag if enabled, will count all the components that can be
merged, else will return on first found range
* @return MergableSolution
*/
- private MergableSolution getMergableIndexesRange(List<ILSMDiskComponent>
diskComponents,
+ private MergableSolution getMergableIndexesRange(List<ILSMDiskComponent>
inputDiskComponents,
int localMinMergeComponentCount, boolean countFlag) {
+ List<ILSMDiskComponent> diskComponents = new
ArrayList<>(inputDiskComponents);
int numComponents = diskComponents.size();
int candidateComponentsCount = 0;
for (; candidateComponentsCount < numComponents;
candidateComponentsCount++) {
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20649?usp=email
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings?usp=email
Gerrit-MessageType: newchange
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: I63be765a330bb15d53dfaa0ef1c8679355396628
Gerrit-Change-Number: 20649
Gerrit-PatchSet: 1
Gerrit-Owner: Peeyush Gupta <[email protected]>
