Skip to content

Commit d98dbe4

Browse files
authored
Fixed move errors (#16897)
1 parent 70db6db commit d98dbe4

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

ydb/core/kqp/runtime/kqp_write_actor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2802,7 +2802,7 @@ class TKqpBufferWriteActor :public TActorBootstrapped<TKqpBufferWriteActor>, pub
28022802
void UpdateTracingState(const char* name, NWilson::TTraceId traceId) {
28032803
BufferWriteActorStateSpan = NWilson::TSpan(TWilsonKqp::BufferWriteActorState, std::move(traceId),
28042804
name, NWilson::EFlags::AUTO_END);
2805-
if (traceId != BufferWriteActorSpan.GetTraceId()) {
2805+
if (BufferWriteActorStateSpan.GetTraceId() != BufferWriteActorSpan.GetTraceId()) {
28062806
BufferWriteActorStateSpan.Link(BufferWriteActorSpan.GetTraceId());
28072807
}
28082808
for (auto& [_, info] : WriteInfos) {

ydb/core/kqp/runtime/kqp_write_table.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -245,7 +245,7 @@ class TRowBatch : public IDataBatch {
245245
for (const auto& row : Rows) {
246246
AFL_ENSURE(row.size() == Rows.front().size());
247247
const auto size = EstimateSize(row);
248-
SerializedMemory += GetCellHeaderSize() * rows.Size() + size;
248+
SerializedMemory += GetCellHeaderSize() * row.size() + size;
249249
Memory += size;
250250
}
251251
}

0 commit comments

Comments
 (0)