commit 17016ef608fe763546c13aad96cca8109a46789b
author Ritik Raj <raj.ritik9835@gmail.com> Mon Mar 03 01:39:35 2025 +0530
committer Hussain Towaileb <hussainht@gmail.com> Wed Mar 12 09:36:07 2025 +0000
tree a30758522dfbe9c4a8b1d468e0e970ff0836ff7f
parent b38d2366d029293025d8eadcb6cb1bc39c8a1137

[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 <jenkins@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Ritik Raj <ritik.raj@couchbase.com>
Reviewed-by: Ian Maxon <imaxon@apache.org>

asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/LSMPrimaryInsertOperatorNodePushable.java

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);