This is an automated email from the ASF dual-hosted git repository. mhubail pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit 17016ef608fe763546c13aad96cca8109a46789b Author: Ritik Raj <[email protected]> AuthorDate: Mon Mar 3 01:39:35 2025 +0530 [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]> --- .../runtime/operators/LSMPrimaryInsertOperatorNodePushable.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 9b8b103d55..9d4377ad71 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 @@ public class LSMPrimaryInsertOperatorNodePushable extends LSMIndexInsertUpdateDe 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 @@ public class LSMPrimaryInsertOperatorNodePushable extends LSMIndexInsertUpdateDe LSMIndexUtil.checkAndSetFirstLSN((AbstractLSMIndex) index, appCtx.getTransactionSubsystem().getLogManager()); } + writer.open(); + writerOpen = true; createTupleProcessors(sourceLoc); keySearchCmp = BTreeUtils.getSearchMultiComparator(((ITreeIndex) indexes[0]).getComparatorFactories(), frameTuple);
