We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 90805a4 + 3ee9d36 commit d8cb87eCopy full SHA for d8cb87e
ydb/core/tx/datashard/cdc_stream_heartbeat.cpp
@@ -33,6 +33,10 @@ class TDataShard::TTxCdcStreamEmitHeartbeats: public NTabletFlatExecutor::TTrans
33
TTxType GetTxType() const override { return TXTYPE_CDC_STREAM_EMIT_HEARTBEATS; }
34
35
bool Execute(TTransactionContext& txc, const TActorContext&) override {
36
+ if (Self->State != TShardState::Ready) {
37
+ return true;
38
+ }
39
+
40
LOG_I("Emit change records"
41
<< ": edge# " << Edge
42
<< ", at tablet# " << Self->TabletID());
0 commit comments