File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
ydb/core/tx/columnshard/operations Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -215,10 +215,12 @@ TWriteOperation::TPtr TOperationsManager::CreateWriteOperation(const TUnifiedPat
215
215
}
216
216
217
217
TConclusion<EOperationBehaviour> TOperationsManager::GetBehaviour (const NEvents::TDataEvents::TEvWrite& evWrite) {
218
+ // FIXME #23784
218
219
if (evWrite.Record .HasLocks () && evWrite.Record .GetLocks ().GetOp () == NKikimrDataEvents::TKqpLocks::Rollback) {
219
- AFL_VERIFY_DEBUG (!evWrite.Record .HasTxId ())(" TxId" , evWrite.Record .GetTxId ());
220
+ // AFL_VERIFY_DEBUG(!evWrite.Record.HasTxId())("TxId", evWrite.Record.GetTxId());
220
221
AFL_VERIFY_DEBUG (evWrite.Record .GetTxMode () == NKikimrDataEvents::TEvWrite::MODE_IMMEDIATE)(" TxMode" , evWrite.Record .GetTxMode ());
221
- if (!evWrite.Record .HasTxId () && evWrite.Record .GetTxMode () == NKikimrDataEvents::TEvWrite::MODE_IMMEDIATE) {
222
+ // if (!evWrite.Record.HasTxId() && evWrite.Record.GetTxMode() == NKikimrDataEvents::TEvWrite::MODE_IMMEDIATE) {
223
+ if (evWrite.Record .GetTxMode () == NKikimrDataEvents::TEvWrite::MODE_IMMEDIATE) {
222
224
return EOperationBehaviour::AbortWriteLock;
223
225
}
224
226
else {
You can’t perform that action at this time.
0 commit comments