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.
1 parent 06d06f1 commit d444402Copy full SHA for d444402
ydb/core/persqueue/pqtablet/pq_impl.cpp
@@ -811,10 +811,7 @@ void TPersQueue::ReadConfig(const NKikimrClient::TKeyValueResponse::TReadResult&
811
NKikimrPQ::TTransaction tx;
812
PQ_ENSURE(tx.ParseFromString(pair.GetValue()));
813
814
- if (tx.GetKind() == NKikimrPQ::TTransaction::KIND_UNKNOWN) {
815
- PQ_LOG_TX_W("Invalid transaction state. Key " << pair.GetKey());
816
- continue;
817
- }
+ PQ_ENSURE(tx.GetKind() != NKikimrPQ::TTransaction::KIND_UNKNOWN)("Key", pair.GetKey());
818
819
PQ_LOG_TX_I("Restore Tx. " <<
820
"TxId: " << tx.GetTxId() <<
0 commit comments