Skip to content

Commit 05fc058

Browse files
zhli1142015xieqi
authored andcommitted
Fix metrics on operator's noMoreInput (#310)
1 parent bfa3db5 commit 05fc058

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

velox/exec/Driver.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -423,9 +423,9 @@ StopReason Driver::runInternal(
423423
}
424424
RuntimeStatWriterScopeGuard statsWriterGuard(op);
425425
if (op->isFinished()) {
426-
auto timer =
427-
createDeltaCpuWallTimer([op](const CpuWallTiming& timing) {
428-
op->stats().wlock()->finishTiming.add(timing);
426+
auto timer = createDeltaCpuWallTimer(
427+
[nextOp](const CpuWallTiming& timing) {
428+
nextOp->stats().wlock()->finishTiming.add(timing);
429429
});
430430
RuntimeStatWriterScopeGuard statsWriterGuard(nextOp);
431431
nextOp->noMoreInput();

0 commit comments

Comments
 (0)