Skip to content

Commit d934df0

Browse files
zhli1142015zhejiangxiaomai
authored andcommitted
Fix metrics on operator's noMoreInput (#310)
1 parent 99dac79 commit d934df0

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
@@ -446,9 +446,9 @@ StopReason Driver::runInternal(
446446
}
447447
RuntimeStatWriterScopeGuard statsWriterGuard(op);
448448
if (op->isFinished()) {
449-
auto timer =
450-
createDeltaCpuWallTimer([op](const CpuWallTiming& timing) {
451-
op->stats().wlock()->finishTiming.add(timing);
449+
auto timer = createDeltaCpuWallTimer(
450+
[nextOp](const CpuWallTiming& timing) {
451+
nextOp->stats().wlock()->finishTiming.add(timing);
452452
});
453453
RuntimeStatWriterScopeGuard statsWriterGuard(nextOp);
454454
TestValue::adjust(

0 commit comments

Comments
 (0)