You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-08-01 06:46:55 +03:00
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
This commit is contained in:
@ -329,8 +329,11 @@ void DistributedEngineComm::Setup()
|
|||||||
|
|
||||||
for (j = 0; j < pmCount; j++)
|
for (j = 0; j < pmCount; j++)
|
||||||
{
|
{
|
||||||
if (newClients[i]->isSameAddr(*fPmConnections[j]))
|
if (!fPmConnections.empty() && j < fPmConnections.size() &&
|
||||||
|
newClients[i]->isSameAddr(*fPmConnections[j]))
|
||||||
|
{
|
||||||
break;
|
break;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (j == pmCount)
|
if (j == pmCount)
|
||||||
|
@ -171,6 +171,8 @@ ResourceManager::ResourceManager(bool runningInExeMgr) :
|
|||||||
totalUmMemLimit = pmJoinMemLimit;
|
totalUmMemLimit = pmJoinMemLimit;
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
// Installation.PMwithUM = y by default so RM prefers HashJoin.TotalPmUmMemory
|
||||||
|
// if it exists.
|
||||||
string whichLimit = "TotalUmMemory";
|
string whichLimit = "TotalUmMemory";
|
||||||
string pmWithUM = fConfig->getConfig("Installation", "PMwithUM");
|
string pmWithUM = fConfig->getConfig("Installation", "PMwithUM");
|
||||||
|
|
||||||
|
@ -443,7 +443,7 @@
|
|||||||
<InitialInstallFlag>y</InitialInstallFlag>
|
<InitialInstallFlag>y</InitialInstallFlag>
|
||||||
<SingleServerInstall>y</SingleServerInstall>
|
<SingleServerInstall>y</SingleServerInstall>
|
||||||
<ServerTypeInstall>2</ServerTypeInstall>
|
<ServerTypeInstall>2</ServerTypeInstall>
|
||||||
<PMwithUM>n</PMwithUM>
|
<PMwithUM>y</PMwithUM>
|
||||||
<MySQLRep>n</MySQLRep>
|
<MySQLRep>n</MySQLRep>
|
||||||
<DBRootStorageType>internal</DBRootStorageType>
|
<DBRootStorageType>internal</DBRootStorageType>
|
||||||
<UMStorageType>internal</UMStorageType>
|
<UMStorageType>internal</UMStorageType>
|
||||||
|
Reference in New Issue
Block a user