diff options
author | Nikita Vasilev <31595000+nikvas0@users.noreply.github.com> | 2024-01-22 14:03:50 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-01-22 14:03:50 +0300 |
commit | 185fc0d632f78add8fdd8ddb71584d4f2f60a4d6 (patch) | |
tree | 9ea888311d1e945943fb95254030d7656e939fe2 | |
parent | 9bc2bf29b0b82680dc6de17c1b0eb5dae8ab270c (diff) | |
download | ydb-185fc0d632f78add8fdd8ddb71584d4f2f60a4d6.tar.gz |
Fix ShardHint for read actor
-rw-r--r-- | ydb/core/kqp/executer_actor/kqp_executer_impl.h | 7 |
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); } |