diff options
author | ssmike <ssmike@ydb.tech> | 2023-06-16 23:24:37 +0300 |
---|---|---|
committer | ssmike <ssmike@ydb.tech> | 2023-06-16 23:24:37 +0300 |
commit | bae1554613ac32a1a6516508ad731673919320b6 (patch) | |
tree | 74b0a2a673a9c8580f1746d274787f8f4716e1af | |
parent | 7f8f327ecc4ac0d9fcfcb9e6dfba03e20a7ff8b7 (diff) | |
download | ydb-bae1554613ac32a1a6516508ad731673919320b6.tar.gz |
Speed-up sequential reads
-rw-r--r-- | ydb/core/kqp/runtime/kqp_read_actor.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/kqp/runtime/kqp_read_actor.cpp b/ydb/core/kqp/runtime/kqp_read_actor.cpp index 065e17f013..4f9a32475c 100644 --- a/ydb/core/kqp/runtime/kqp_read_actor.cpp +++ b/ydb/core/kqp/runtime/kqp_read_actor.cpp @@ -1185,8 +1185,6 @@ public: ResetRead(id); } - StartShards(); - Results.pop(); CA_LOG_D("dropping batch for read #" << id); @@ -1194,6 +1192,8 @@ public: finished = true; break; } + + StartShards(); } else { break; } |