We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
PQ/BytesWriteOK
1 parent 9b0016b commit 7e2de89Copy full SHA for 7e2de89
ydb/core/persqueue/partition_write.cpp
@@ -452,6 +452,12 @@ void TPartition::SyncMemoryStateWithKVState(const TActorContext& ctx) {
452
void TPartition::OnHandleWriteResponse(const TActorContext& ctx)
453
{
454
KVWriteInProgress = false;
455
+
456
+ if (DeletePartitionState == DELETION_IN_PROCESS) {
457
+ // before deleting an supportive partition, it is necessary to summarize its work
458
+ HandleWakeup(ctx);
459
+ }
460
461
OnProcessTxsAndUserActsWriteComplete(ctx);
462
HandleWriteResponse(ctx);
463
ProcessTxsAndUserActs(ctx);
0 commit comments