From 69550cbe78007da82aebcdd3b31f30834895f110 Mon Sep 17 00:00:00 2001
From: Jose Rojas <jose.rojas@mariadb.com>
Date: Wed, 2 Dec 2020 17:10:20 +0000
Subject: [PATCH] MCOL-2055 Fix. Flush PrimProc Cache during batchinserts

---
 writeengine/wrapper/writeengine.cpp | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/writeengine/wrapper/writeengine.cpp b/writeengine/wrapper/writeengine.cpp
index f965a6485..790530c68 100644
--- a/writeengine/wrapper/writeengine.cpp
+++ b/writeengine/wrapper/writeengine.cpp
@@ -1681,6 +1681,13 @@ int WriteEngineWrapper::insertColumnRecs(const TxnID& txnid,
         // Write row(s) to database file(s)
         //----------------------------------------------------------------------
         rc = writeColumnRec(txnid, cscColTypeList, colStructList, colOldValueList, rowIdArray, newColStructList, colNewValueList, tableOid, useTmpSuffix); // @bug 5572 HDFS tmp file
+
+        if (rc == NO_ERROR)
+        {
+            rc = cacheutils::flushPrimProcCache();
+            if (rc != 0)
+                rc = ERR_BLKCACHE_FLUSH_LIST; // translate to WE error
+        }
     }
 
     return rc;