diff --git a/velox/exec/tests/TaskTest.cpp b/velox/exec/tests/TaskTest.cpp index c6c71a86a6dd..58a1293859b5 100644 --- a/velox/exec/tests/TaskTest.cpp +++ b/velox/exec/tests/TaskTest.cpp @@ -1241,7 +1241,7 @@ DEBUG_ONLY_TEST_F(TaskTest, liveStats) { EXPECT_EQ(numBatches, operatorStats.outputVectors); // isBlocked() should be called at least twice for each batch EXPECT_LE(2 * numBatches, operatorStats.isBlockedTiming.count); - EXPECT_EQ(2, operatorStats.finishTiming.count); + EXPECT_EQ(1, operatorStats.finishTiming.count); // No operators with background CPU time yet. EXPECT_EQ(0, operatorStats.backgroundTiming.count);