>From Ritik Raj <[email protected]>:
Ritik Raj has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19483 )
Change subject: [NO ISSUE][RT] Fixing LogMarkerTest
......................................................................
[NO ISSUE][RT] Fixing LogMarkerTest
- user model changes: no
- storage format changes: no
- interface changes: no
Change-Id: I141467aeccbc90de29267c577298de0f86a69c2f
---
M
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/LSMPrimaryInsertOperatorNodePushable.java
1 file changed, 15 insertions(+), 2 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/83/19483/1
diff --git
a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/LSMPrimaryInsertOperatorNodePushable.java
b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/LSMPrimaryInsertOperatorNodePushable.java
index 9b8b103..9d4377a 100644
---
a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/LSMPrimaryInsertOperatorNodePushable.java
+++
b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/LSMPrimaryInsertOperatorNodePushable.java
@@ -235,8 +235,6 @@
try {
INcApplicationContext appCtx =
(INcApplicationContext)
ctx.getJobletContext().getServiceContext().getApplicationContext();
- writer.open();
- writerOpen = true;
for (int i = 0; i < partitions.length; i++) {
IIndexDataflowHelper indexHelper = indexHelpers[i];
indexHelpersOpen[i] = true;
@@ -282,6 +280,8 @@
LSMIndexUtil.checkAndSetFirstLSN((AbstractLSMIndex) index,
appCtx.getTransactionSubsystem().getLogManager());
}
+ writer.open();
+ writerOpen = true;
createTupleProcessors(sourceLoc);
keySearchCmp =
BTreeUtils.getSearchMultiComparator(((ITreeIndex)
indexes[0]).getComparatorFactories(), frameTuple);
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19483
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: I141467aeccbc90de29267c577298de0f86a69c2f
Gerrit-Change-Number: 19483
Gerrit-PatchSet: 1
Gerrit-Owner: Ritik Raj <[email protected]>
Gerrit-MessageType: newchange
