Skip to content

Commit 2b752b4

Browse files
authored
Fix reads merge option (#13015)
1 parent dcaad01 commit 2b752b4

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/core/kqp/executer_actor/kqp_data_executer.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2017,8 +2017,8 @@ class TKqpDataExecuter : public TKqpExecuterBase<TKqpDataExecuter, EExecType::Da
20172017
case NKqpProto::TKqpSource::kReadRangesSource:
20182018
if (auto partitionsCount = BuildScanTasksFromSource(
20192019
stageInfo,
2020-
/* shardsResolved */ StreamResult,
2021-
/* limitTasksPerNode */ StreamResult)) {
2020+
/* shardsResolved */ StreamResult || EnableReadsMerge,
2021+
/* limitTasksPerNode */ StreamResult || EnableReadsMerge)) {
20222022
sourceScanPartitionsCount += *partitionsCount;
20232023
} else {
20242024
UnknownAffectedShardCount = true;
@@ -2187,7 +2187,7 @@ class TKqpDataExecuter : public TKqpExecuterBase<TKqpDataExecuter, EExecType::Da
21872187
void HandleResolve(TEvKqpExecuter::TEvTableResolveStatus::TPtr& ev) {
21882188
if (!TBase::HandleResolve(ev)) return;
21892189

2190-
if (StreamResult || AllowOlapDataQuery) {
2190+
if (StreamResult || EnableReadsMerge || AllowOlapDataQuery) {
21912191
TSet<ui64> shardIds;
21922192
for (auto& [stageId, stageInfo] : TasksGraph.GetStagesInfo()) {
21932193
if (stageInfo.Meta.IsOlap()) {

0 commit comments

Comments
 (0)