Skip to content

Commit

Permalink
Merge pull request #18020 from shamser/issue30812
Browse files Browse the repository at this point in the history
HPCC-30812 Fix bug in IoSkewRule of wu cost optimizer

Reviewed-by: Gavin Halliday <[email protected]>
Merged-by: Gavin Halliday <[email protected]>
  • Loading branch information
ghalliday authored Nov 23, 2023
2 parents 0f0f911 + fb9faa6 commit fa49bc6
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions common/wuanalysis/anarule.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -151,13 +151,13 @@ class IoSkewRule : public AActivityRule
{
if (activity.getStatRaw(StSizeDiskWrite, StSkewMax)>options.queryOption(watOptSkewThreshold))
sizeSkew = true;
IWuEdge *wuEdge = activity.queryInput(0);
wuEdge = activity.queryInput(0);
}
else if ((stat == StTimeDiskReadIO) || (actkind==TAKspillread))
{
if (activity.getStatRaw(StSizeDiskRead, StSkewMax)>options.queryOption(watOptSkewThreshold))
sizeSkew = true;
IWuEdge *wuEdge = activity.queryOutput(0);
wuEdge = activity.queryOutput(0);
}
if (wuEdge && wuEdge->getStatRaw(StNumRowsProcessed, StSkewMax)>options.queryOption(watOptSkewThreshold))
numRowsSkew = true;
Expand Down

0 comments on commit fa49bc6

Please sign in to comment.