aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorNikita Vasilev <31595000+nikvas0@users.noreply.github.com>2024-01-22 14:03:50 +0300
committerGitHub <noreply@github.com>2024-01-22 14:03:50 +0300
commit185fc0d632f78add8fdd8ddb71584d4f2f60a4d6 (patch)
tree9ea888311d1e945943fb95254030d7656e939fe2
parent9bc2bf29b0b82680dc6de17c1b0eb5dae8ab270c (diff)
downloadydb-185fc0d632f78add8fdd8ddb71584d4f2f60a4d6.tar.gz
Fix ShardHint for read actor
-rw-r--r--ydb/core/kqp/executer_actor/kqp_executer_impl.h7
1 files changed, 6 insertions, 1 deletions
diff --git a/ydb/core/kqp/executer_actor/kqp_executer_impl.h b/ydb/core/kqp/executer_actor/kqp_executer_impl.h
index d0350fec89..a190b06670 100644
--- a/ydb/core/kqp/executer_actor/kqp_executer_impl.h
+++ b/ydb/core/kqp/executer_actor/kqp_executer_impl.h
@@ -949,7 +949,7 @@ protected:
settings->SetMaxInFlightShards(*maxInFlightShards);
}
- if (!limitTasksPerNode && shardId) {
+ if (shardId) {
settings->SetShardIdHint(*shardId);
}
@@ -1025,6 +1025,11 @@ protected:
NKikimrTxDataShard::TKqpReadRangesSourceSettings* settings = input.Meta.SourceSettings;
const auto& shardsRangesForTask = rangesDistribution[taskIndex];
+
+ if (shardsRangesForTask.size() > 1) {
+ settings->ClearShardIdHint();
+ }
+
for (const auto& shardRanges : shardsRangesForTask) {
shardRanges->SerializeTo(settings);
}