>From Hussain Towaileb <[email protected]>: Hussain Towaileb has submitted this change. ( https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19483 )
( 1 is the latest approved patch-set. No files were changed between the latest approved patch-set and the submitted one. )Change subject: [NO ISSUE][RT] Fixing LogMarkerTest ...................................................................... [NO ISSUE][RT] Fixing LogMarkerTest - user model changes: no - storage format changes: no - interface changes: no Ext-ref: MB-65586 Change-Id: I141467aeccbc90de29267c577298de0f86a69c2f Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19483 Tested-by: Jenkins <[email protected]> Integration-Tests: Jenkins <[email protected]> Reviewed-by: Ritik Raj <[email protected]> Reviewed-by: Ian Maxon <[email protected]> --- M asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/LSMPrimaryInsertOperatorNodePushable.java 1 file changed, 22 insertions(+), 2 deletions(-) Approvals: Ian Maxon: Looks good to me, approved Ritik Raj: Looks good to me, but someone else must approve Jenkins: Verified; Verified Anon. E. Moose #1000171: 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: 4 Gerrit-Owner: Ritik Raj <[email protected]> Gerrit-Reviewer: Anon. E. Moose #1000171 Gerrit-Reviewer: Hussain Towaileb <[email protected]> Gerrit-Reviewer: Ian Maxon <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Murtadha Hubail <[email protected]> Gerrit-Reviewer: Ritik Raj <[email protected]> Gerrit-MessageType: merged
