Murtadha Hubail has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2259
Change subject: [ASTERIXDB-2219][STO] Skip Empty Components Replication
......................................................................
[ASTERIXDB-2219][STO] Skip Empty Components Replication
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
- Skip replication for empty components on flushes
and merges.
Change-Id: If1453f813dafa2aa6c40039fac1d0aea2f08a4e2
---
M
hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMHarness.java
1 file changed, 2 insertions(+), 2 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/59/2259/1
diff --git
a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMHarness.java
b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMHarness.java
index 15ed0ff..b2c48e1 100644
---
a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMHarness.java
+++
b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMHarness.java
@@ -342,7 +342,7 @@
// newComponent is null if the flush op. was not performed.
if (!failedOperation && newComponent != null) {
lsmIndex.addDiskComponent(newComponent);
- if (replicationEnabled) {
+ if (replicationEnabled && newComponent !=
EmptyComponent.INSTANCE) {
componentsToBeReplicated.clear();
componentsToBeReplicated.add(newComponent);
triggerReplication(componentsToBeReplicated, false,
opType);
@@ -354,7 +354,7 @@
// newComponent is null if the merge op. was not performed.
if (!failedOperation && newComponent != null) {
lsmIndex.subsumeMergedComponents(newComponent,
ctx.getComponentHolder());
- if (replicationEnabled) {
+ if (replicationEnabled && newComponent !=
EmptyComponent.INSTANCE) {
componentsToBeReplicated.clear();
componentsToBeReplicated.add(newComponent);
triggerReplication(componentsToBeReplicated, false,
opType);
--
To view, visit https://asterix-gerrit.ics.uci.edu/2259
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: If1453f813dafa2aa6c40039fac1d0aea2f08a4e2
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Murtadha Hubail <[email protected]>
