Skip to content

Commit c9838ae

Browse files
authored
Fix CopyToChunked for empty batch (#9288)
1 parent 0160e70 commit c9838ae

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ydb/core/kqp/executer_actor/kqp_executer_impl.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ void TEvKqpExecuter::TEvTxResponse::TakeResult(ui32 idx, NDq::TDqSerializedBatch
3939
ResultRowsBytes += rows.Size();
4040
auto guard = AllocState->TypeEnv.BindAllocator();
4141
auto& result = TxResults[idx];
42-
if (rows.RowCount() || !result.IsStream) {
42+
if (rows.RowCount()) {
4343
NDq::TDqDataSerializer dataSerializer(
4444
AllocState->TypeEnv, AllocState->HolderFactory,
4545
static_cast<NDqProto::EDataTransportVersion>(rows.Proto.GetTransportVersion()));

0 commit comments

Comments
 (0)