database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-07-16 04:01:52 +03:00
Code Activity

Removed a debugging printout, used RM to get core count.

Browse Source
This commit is contained in:
Patrick LeBlanc
2019-11-22 10:38:05 -05:00
parent c866715efe
commit acdd8ca9f1
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
dbcon/joblist/tuplehashjoin.cpp
View File

@ -116,7 +116,7 @@ TupleHashJoinStep::TupleHashJoinStep(const JobInfo& jobInfo) :
else else
allowDJS = false; allowDJS = false;
numCores = sysconf(_SC_NPROCESSORS_ONLN); numCores = resourceManager->numCores();
if (numCores <= 0) if (numCores <= 0)
numCores = 8; numCores = 8;
/* Debugging, rand() is used to simulate failures /* Debugging, rand() is used to simulate failures
@ -284,8 +284,10 @@ void TupleHashJoinStep::startSmallRunners(uint index)
handle abort, out of memory, etc handle abort, out of memory, etc
*/ */
/* To measure wall-time spent constructing the small-side tables...
boost::posix_time::ptime end_time, start_time = boost::posix_time::ptime end_time, start_time =
boost::posix_time::microsec_clock::universal_time(); boost::posix_time::microsec_clock::universal_time();
*/
stopMemTracking = false; stopMemTracking = false;
uint64_t jobs[numCores]; uint64_t jobs[numCores];
@ -324,12 +326,13 @@ void TupleHashJoinStep::startSmallRunners(uint index)
while (more) while (more)
more = smallDLs[index]->next(smallIts[index], &oneRG); more = smallDLs[index]->next(smallIts[index], &oneRG);
} }
//joiner->doneInserting();
/* To measure wall-time spent constructing the small-side tables...
end_time = boost::posix_time::microsec_clock::universal_time(); end_time = boost::posix_time::microsec_clock::universal_time();
if (!(fSessionId & 0x80000000)) if (!(fSessionId & 0x80000000))
cout << "hash table construction time = " << end_time - start_time << cout << "hash table construction time = " << end_time - start_time <<
" size = " << joiner->size() << endl; " size = " << joiner->size() << endl;
*/
extendedInfo += "\n"; extendedInfo += "\n";