diff options
author | ssmike <ssmike@ydb.tech> | 2023-01-26 02:08:48 +0300 |
---|---|---|
committer | ssmike <ssmike@ydb.tech> | 2023-01-26 02:08:48 +0300 |
commit | d67291f6f90ba2cce679652aef3a02dd31c696fa (patch) | |
tree | 0d702686e03e621cb75e1f1d63820cf5a5f9c5ca | |
parent | 252723c46e7003fc87b6545a53370e25a4be74d0 (diff) | |
download | ydb-d67291f6f90ba2cce679652aef3a02dd31c696fa.tar.gz |
fix arrow for readranges source
-rw-r--r-- | ydb/core/kqp/runtime/kqp_read_actor.cpp | 6 |
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 { |