commit 93d3c91ae36b0440c6f0f79b16a63a3837b1bb56
author luochen <cluo8@uci.edu> Wed Apr 15 21:55:06 2020 -0700
committer Luo Chen <cluo8@uci.edu> Thu Apr 23 22:52:38 2020 +0000
tree b352cae12ac36cf34d22b55789607e3a3e051a0b
parent f2c93085c81628eb9bc7e563259eaf9e4fe7a3bc

[NO ISSUE] Fix log marker of insert

- user model changes: no
- storage format changes: no
- interface changes: no

Details:
- Fix the log marker of the insert operator by ensuring
that the downstream operator is opened after the log
marker callback is set.

Change-Id: I5f131f205465265ecd843b869478f7b48839c609
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/5825
Reviewed-by: Luo Chen <cluo8@uci.edu>
Reviewed-by: Murtadha Hubail <mhubail@apache.org>
Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

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 121b5b9..0bb42d4 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
@@ -168,7 +168,6 @@
         flushedPartialTuples = false;
         accessor = new FrameTupleAccessor(inputRecDesc);
         writeBuffer = new VSizeFrame(ctx);
-        writer.open();
         indexHelper.open();
         index = indexHelper.getIndexInstance();
         IIndex indexForUniquessCheck;
@@ -183,6 +182,7 @@
                 PrimaryIndexLogMarkerCallback callback = new PrimaryIndexLogMarkerCallback((AbstractLSMIndex) index);
                 TaskUtil.put(ILogMarkerCallback.KEY_MARKER_CALLBACK, callback, ctx);
             }
+            writer.open();
             keySearchCmp =
                     BTreeUtils.getSearchMultiComparator(((ITreeIndex) index).getComparatorFactories(), frameTuple);
             searchPred = new RangePredicate(frameTuple, frameTuple, true, true, keySearchCmp, keySearchCmp, null, null);