aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorssmike <ssmike@ydb.tech>2023-01-26 02:08:48 +0300
committerssmike <ssmike@ydb.tech>2023-01-26 02:08:48 +0300
commitd67291f6f90ba2cce679652aef3a02dd31c696fa (patch)
tree0d702686e03e621cb75e1f1d63820cf5a5f9c5ca
parent252723c46e7003fc87b6545a53370e25a4be74d0 (diff)
downloadydb-d67291f6f90ba2cce679652aef3a02dd31c696fa.tar.gz
fix arrow for readranges source
-rw-r--r--ydb/core/kqp/runtime/kqp_read_actor.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/kqp/runtime/kqp_read_actor.cpp b/ydb/core/kqp/runtime/kqp_read_actor.cpp
index c86769e9398..dbebf28b75d 100644
--- a/ydb/core/kqp/runtime/kqp_read_actor.cpp
+++ b/ydb/core/kqp/runtime/kqp_read_actor.cpp
@@ -596,7 +596,6 @@ public:
void HandleRead(TEvDataShard::TEvReadResult::TPtr ev) {
const auto& record = ev->Get()->Record;
auto id = record.GetReadId();
- Y_VERIFY(id < ReadId);
if (!Reads[id] || Reads[id].Finished) {
// dropped read
return;
@@ -619,8 +618,6 @@ public:
Reads[id].RegisterMessage(*ev->Get());
- YQL_ENSURE(record.GetResultFormat() == NKikimrTxDataShard::EScanDataFormat::CELLVEC);
-
RecievedRowCount += ev->Get()->GetRowsCount();
Results.push({Reads[id].Shard->TabletId, THolder<TEventHandle<TEvDataShard::TEvReadResult>>(ev.Release())});
CA_LOG_D(TStringBuilder() << "new data for read #" << id << " pushed");
@@ -670,6 +667,9 @@ public:
{
NMiniKQL::TBytesStatistics stats;
bool hasResultColumns = false;
+ if (result->Get()->GetRowsCount() == 0) {
+ return {};
+ }
if (Settings.ColumnsSize() == 0) {
batch.resize(result->Get()->GetRowsCount(), HolderFactory.GetEmptyContainer());
} else {