Skip to content

Commit c1bcd71

Browse files
authored
24-3: Check shard state at TTxCdcStreamEmitHeartbeats (#7148)
1 parent 3606e07 commit c1bcd71

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

ydb/core/tx/datashard/cdc_stream_heartbeat.cpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,10 @@ class TDataShard::TTxCdcStreamEmitHeartbeats: public NTabletFlatExecutor::TTrans
3333
TTxType GetTxType() const override { return TXTYPE_CDC_STREAM_EMIT_HEARTBEATS; }
3434

3535
bool Execute(TTransactionContext& txc, const TActorContext&) override {
36+
if (Self->State != TShardState::Ready) {
37+
return true;
38+
}
39+
3640
LOG_I("Emit change records"
3741
<< ": edge# " << Edge
3842
<< ", at tablet# " << Self->TabletID());

0 commit comments

Comments
 (0)