Skip to content

Commit c859f59

Browse files
committed
Fix build
1 parent 14faff2 commit c859f59

File tree

4 files changed

+8
-3
lines changed

4 files changed

+8
-3
lines changed

ydb/core/change_exchange/change_sender_common_ops.h

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -419,9 +419,11 @@ class TBaseChangeSender {
419419
if (partitionIds) {
420420
CreateMissingSenders(partitionIds);
421421
} else {
422-
RecreateSenders(std::exchange(GonePartitions, {}));
422+
RecreateSenders(GonePartitions);
423423
}
424424

425+
GonePartitions.clear();
426+
425427
if (!Enqueued || !RequestRecords()) {
426428
SendRecords();
427429
}

ydb/core/scheme/scheme_tablecell.h

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -541,6 +541,10 @@ class TSerializedCellVec {
541541
return Cells;
542542
}
543543

544+
explicit operator bool() const {
545+
return !Cells.empty();
546+
}
547+
544548
static void Serialize(TString& res, TConstArrayRef<TCell> cells);
545549

546550
static TString Serialize(TConstArrayRef<TCell> cells);

ydb/core/tx/datashard/change_sender_cdc_stream.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -521,7 +521,6 @@ class TCdcChangeSenderMain
521521
TopicVersion = topicVersion;
522522

523523
const auto& pqDesc = entry.PQGroupInfo->Description;
524-
const auto& pqConfig = pqDesc.GetPQTabletConfig();
525524

526525
PartitionToShard.clear();
527526
for (const auto& partition : pqDesc.GetPartitions()) {

ydb/core/tx/replication/service/table_writer_impl.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,7 @@ class TLocalTableWriter
342342
if (TableVersion && TableVersion == entry.Self->Info.GetVersion().GetGeneralVersion()) {
343343
Y_ABORT_UNLESS(Initialized);
344344
Resolving = false;
345-
return CreateSenders();
345+
return this->CreateSenders();
346346
}
347347

348348
auto schema = MakeIntrusive<TLightweightSchema>();

0 commit comments

Comments
 (0)