Skip to content

Commit 84b38f0

Browse files
committed
fix for new partitioning
1 parent ea9a52d commit 84b38f0

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

ydb/core/tx/schemeshard/schemeshard_impl.cpp

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7091,7 +7091,9 @@ void TSchemeShard::SetPartitioning(TPathId pathId, TTableInfo::TPtr tableInfo, T
70917091
UpdateShardMetrics(p.ShardIdx, it->second);
70927092
dataErasureShards.push_back(p.ShardIdx);
70937093
}
7094-
Execute(CreateTxAddEntryToDataErasure(dataErasureShards), this->ActorContext());
7094+
if (DataErasureManager->GetStatus() == EDataErasureStatus::IN_PROGRESS) {
7095+
Execute(CreateTxAddEntryToDataErasure(dataErasureShards), this->ActorContext());
7096+
}
70957097
}
70967098

70977099
std::vector<TShardIdx> cancelDataErasureShards;
@@ -7101,7 +7103,9 @@ void TSchemeShard::SetPartitioning(TPathId pathId, TTableInfo::TPtr tableInfo, T
71017103
OnShardRemoved(p.ShardIdx);
71027104
cancelDataErasureShards.push_back(p.ShardIdx);
71037105
}
7104-
Execute(CreateTxCancelDataErasureShards(cancelDataErasureShards), this->ActorContext());
7106+
if (DataErasureManager->GetStatus() == EDataErasureStatus::IN_PROGRESS) {
7107+
Execute(CreateTxCancelDataErasureShards(cancelDataErasureShards), this->ActorContext());
7108+
}
71057109
}
71067110
}
71077111

0 commit comments

Comments
 (0)