From 14dbb6a8fbb366f2381739669ff6a09d8afec3fb Mon Sep 17 00:00:00 2001
From: Roman Nozdrin <roman.nozdrin@mariadb.com>
Date: Wed, 23 Jun 2021 10:38:46 +0000
Subject: [PATCH] MCOL-4770 Installation.PMwithUM is enabled by default so a
 plugin communicates with a local EM only Fix in DEC::Setup to allow to
 re-establish all PM connections in EM

---
 dbcon/joblist/distributedenginecomm.cpp | 5 ++++-
 dbcon/joblist/resourcemanager.cpp       | 2 ++
 oam/etc/Columnstore.xml                 | 2 +-
 3 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/dbcon/joblist/distributedenginecomm.cpp b/dbcon/joblist/distributedenginecomm.cpp
index 6fbbee3c5..01f29e75d 100644
--- a/dbcon/joblist/distributedenginecomm.cpp
+++ b/dbcon/joblist/distributedenginecomm.cpp
@@ -329,8 +329,11 @@ void DistributedEngineComm::Setup()
 
         for (j = 0; j < pmCount; j++)
         {
-            if (newClients[i]->isSameAddr(*fPmConnections[j]))
+            if (!fPmConnections.empty() && j < fPmConnections.size() &&
+                newClients[i]->isSameAddr(*fPmConnections[j]))
+            {
                 break;
+            }
         }
 
         if (j == pmCount)
diff --git a/dbcon/joblist/resourcemanager.cpp b/dbcon/joblist/resourcemanager.cpp
index 7ac2f98cb..b9f207d5b 100644
--- a/dbcon/joblist/resourcemanager.cpp
+++ b/dbcon/joblist/resourcemanager.cpp
@@ -171,6 +171,8 @@ ResourceManager::ResourceManager(bool runningInExeMgr) :
         totalUmMemLimit = pmJoinMemLimit;
     else
     {
+        // Installation.PMwithUM = y by default so RM prefers HashJoin.TotalPmUmMemory
+        // if it exists.
         string whichLimit = "TotalUmMemory";
         string pmWithUM = fConfig->getConfig("Installation", "PMwithUM");
 
diff --git a/oam/etc/Columnstore.xml b/oam/etc/Columnstore.xml
index b7caf0b62..df95e40ad 100644
--- a/oam/etc/Columnstore.xml
+++ b/oam/etc/Columnstore.xml
@@ -443,7 +443,7 @@
 		<InitialInstallFlag>y</InitialInstallFlag>
 		<SingleServerInstall>y</SingleServerInstall>
 		<ServerTypeInstall>2</ServerTypeInstall>
-		<PMwithUM>n</PMwithUM>
+		<PMwithUM>y</PMwithUM>
 		<MySQLRep>n</MySQLRep>
 		<DBRootStorageType>internal</DBRootStorageType>
 		<UMStorageType>internal</UMStorageType>