Skip to content

Commit 9104343

Browse files
zhli1142015zhejiangxiaomai
authored andcommitted
Fix metrics on operator's noMoreInput (oap-project#310)
1 parent cbaa882 commit 9104343

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
@@ -466,9 +466,9 @@ StopReason Driver::runInternal(
466466
}
467467
RuntimeStatWriterScopeGuard statsWriterGuard(op);
468468
if (op->isFinished()) {
469-
auto timer =
470-
createDeltaCpuWallTimer([op](const CpuWallTiming& timing) {
471-
op->stats().wlock()->finishTiming.add(timing);
469+
auto timer = createDeltaCpuWallTimer(
470+
[nextOp](const CpuWallTiming& timing) {
471+
nextOp->stats().wlock()->finishTiming.add(timing);
472472
});
473473
RuntimeStatWriterScopeGuard statsWriterGuard(nextOp);
474474
TestValue::adjust(

0 commit comments

Comments
 (0)