-
Notifications
You must be signed in to change notification settings - Fork 304
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
HPCC-32218 Implement StNumParallelExecute stat for activities #18870
Conversation
Jira Issue: https://hpccsystems.atlassian.net//browse/HPCC-32218 Jirabot Action Result: |
system/jlib/jstats.cpp
Outdated
@@ -983,6 +983,7 @@ static const constexpr StatisticMeta statsMetaData[StMax] = { | |||
{ NUMSTAT(MatchRightRowsMax), "The largest number of right rows in a join group" }, | |||
{ NUMSTAT(MatchCandidates), "The number of candidate combinations of left and right rows forming join groups" }, | |||
{ NUMSTAT(MatchCandidatesMax), "The largest number of candidate combinations of left and right rows in a single group" }, | |||
{ NUMSTAT(Threads), "The number of threads (strands) used by activity" }, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
not necessarily strands in other contexts, e.g. if we start reporting number of threads used by keyed join, hash distrib.. Probably best to just drop "(strands)" here.
thorlcr/thorutil/thormisc.cpp
Outdated
@@ -76,6 +76,7 @@ static Owned<IMPtagAllocator> ClusterMPAllocator; | |||
const StatisticsMapping spillStatistics({StTimeSpillElapsed, StTimeSortElapsed, StNumSpills, StSizeSpillFile, StSizePeakTempDisk}); | |||
const StatisticsMapping soapcallStatistics({StTimeSoapcall}); | |||
const StatisticsMapping basicActivityStatistics({StTimeTotalExecute, StTimeLocalExecute, StTimeBlocked}); | |||
const StatisticsMapping strandedActivityStatistics({StNumThreads}, basicActivityStatistics); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
let's add numThreads to basicActivityStatistics, as many activities use threads, even if project will be the only one for now, that will report it.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@shamser - see minor comments, but looks like it will be a good change.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@shamser - looks good please squash.
@shamser - have pushed a comment to JIRA, can we rename this to “numParallelExecute” ? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@shamser - looks good, please squash
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@shamser - looks good.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@shamser main change looks good. One comment about the description.
system/jlib/jstats.cpp
Outdated
@@ -983,6 +983,7 @@ static const constexpr StatisticMeta statsMetaData[StMax] = { | |||
{ NUMSTAT(MatchRightRowsMax), "The largest number of right rows in a join group" }, | |||
{ NUMSTAT(MatchCandidates), "The number of candidate combinations of left and right rows forming join groups" }, | |||
{ NUMSTAT(MatchCandidatesMax), "The largest number of candidate combinations of left and right rows in a single group" }, | |||
{ NUMSTAT(ParallelExecute), "The number of parallel execution of the activity" }, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
minor: This description doesn't quite make sense. "...parallel execution paths/threads/workers for the...". Worth changing because this is a string presented to the user.
Signed-off-by: Shamser Ahmed <[email protected]>
a398e73
into
hpcc-systems:candidate-9.8.x
Type of change:
Checklist:
Smoketest:
Testing: