We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents eeb2175 + 8740d06 commit 14c8626Copy full SHA for 14c8626
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