aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorssmike <ssmike@ydb.tech>2023-06-16 23:24:37 +0300
committerssmike <ssmike@ydb.tech>2023-06-16 23:24:37 +0300
commitbae1554613ac32a1a6516508ad731673919320b6 (patch)
tree74b0a2a673a9c8580f1746d274787f8f4716e1af
parent7f8f327ecc4ac0d9fcfcb9e6dfba03e20a7ff8b7 (diff)
downloadydb-bae1554613ac32a1a6516508ad731673919320b6.tar.gz
Speed-up sequential reads
-rw-r--r--ydb/core/kqp/runtime/kqp_read_actor.cpp4
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;
}