From eef034e0f9d7ab29a629be4bd2469feea40fa893 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E2=80=9CJiaQi?= <2963103258@qq.com>
Date: Fri, 22 Nov 2024 11:38:03 +0800
Subject: [PATCH] bug fix

---
 .../MergeTree/MergeTreeReadPoolParallelReplicasInOrder.cpp      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Storages/MergeTree/MergeTreeReadPoolParallelReplicasInOrder.cpp b/src/Storages/MergeTree/MergeTreeReadPoolParallelReplicasInOrder.cpp
index 567514deec8..f08c34ea3ea 100644
--- a/src/Storages/MergeTree/MergeTreeReadPoolParallelReplicasInOrder.cpp
+++ b/src/Storages/MergeTree/MergeTreeReadPoolParallelReplicasInOrder.cpp
@@ -108,7 +108,7 @@ MergeTreeReadTaskPtr MergeTreeReadPoolParallelReplicasInOrder::getTask(size_t ta
                             if (marks_in_range > max_marks_in_range)
                                 split = true;
                         }
-                        result.emplace_back(range.begin, range.begin + marks_in_range);
+                        result.emplace_back(range.begin, range.end);
                     }
                     chassert(!result.empty());
                     desc.ranges = MarkRanges{};