database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-12-24 14:20:59 +03:00
Code Activity

MCOL-455 Change resistribute database logic to move all segment files from designated dbroots to others in the system.

Browse Source
This commit is contained in:
David Hall
2017-01-06 13:04:32 -06:00
parent 30bd422537
commit 600e758539
5 changed files with 414 additions and 291 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
writeengine/redistribute/we_redistributeworkerthread.cpp
View File

@@ -356,6 +356,7 @@ int RedistributeWorkerThread::buildEntryList()
if (firstOid)
fSegments.insert(j->segmentNum);
}
#if 0
else if (j->dbRoot == target && j->partitionNum == partition)
{
// the partition already exists on the target dbroot
@@ -367,7 +368,7 @@ int RedistributeWorkerThread::buildEntryList()
logMessage(fErrorMsg, __LINE__);
return fErrorCode;
}
#endif
// workaround for HWM_0 of highest extents of the oid on target dbroot.
if (j->dbRoot == target)
{
@@ -1235,7 +1236,7 @@ void RedistributeWorkerThread::handleDataStart(SBS& sbs, size_t& size)
ostringstream oss;
oss << "=>redistributing: " << fileName << ", oid=" << dc.oid << ", db=" << dc.dbroot
<< ", part=" << dc.partition << ", seg=" << dc.segment << " from db="
<< fMsgHeader.destination; // fMsgHeader has swapped source and destination.
<< fMsgHeader.source;
logMessage(oss.str(), __LINE__);
}
else