From 7b7cef10494610132b7617d028b06f52727aab53 Mon Sep 17 00:00:00 2001 From: Yoshiaki Nishimura Date: Tue, 22 Oct 2024 11:30:12 +0900 Subject: [PATCH] fix scan_block_size --- src/jogasaki/executor/process/impl/ops/scan.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/jogasaki/executor/process/impl/ops/scan.cpp b/src/jogasaki/executor/process/impl/ops/scan.cpp index 8d6b862a..82180d85 100644 --- a/src/jogasaki/executor/process/impl/ops/scan.cpp +++ b/src/jogasaki/executor/process/impl/ops/scan.cpp @@ -207,7 +207,8 @@ operation_status scan::operator()( //NOLINT(readability-function-cognitive-comp return {operation_status_kind::aborted}; } } - if (scan_block_size != 0 && scan_block_size == loop_count ){ + if (scan_block_size != 0 && scan_block_size <= loop_count ){ + loop_count = 0; auto current_time = std::chrono::steady_clock::now(); auto elapsed_time = std::chrono::duration_cast(current_time - previous_time);