From 1add34b9014799a73dd41961bcbed8f9034f481c Mon Sep 17 00:00:00 2001 From: Nikita Vasilev Date: Mon, 16 Sep 2024 16:58:00 +0300 Subject: [PATCH] Fix CopyToChunked for empty batch (#9288) --- ydb/core/kqp/executer_actor/kqp_executer_impl.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ydb/core/kqp/executer_actor/kqp_executer_impl.cpp b/ydb/core/kqp/executer_actor/kqp_executer_impl.cpp index b0c0bd9c1616..c1c617a3a277 100644 --- a/ydb/core/kqp/executer_actor/kqp_executer_impl.cpp +++ b/ydb/core/kqp/executer_actor/kqp_executer_impl.cpp @@ -39,7 +39,7 @@ void TEvKqpExecuter::TEvTxResponse::TakeResult(ui32 idx, NDq::TDqSerializedBatch ResultRowsBytes += rows.Size(); auto guard = AllocState->TypeEnv.BindAllocator(); auto& result = TxResults[idx]; - if (rows.RowCount() || !result.IsStream) { + if (rows.RowCount()) { NDq::TDqDataSerializer dataSerializer( AllocState->TypeEnv, AllocState->HolderFactory, static_cast(rows.Proto.GetTransportVersion()));