File tree Expand file tree Collapse file tree 2 files changed +168
-31
lines changed Expand file tree Collapse file tree 2 files changed +168
-31
lines changed Original file line number Diff line number Diff line change @@ -996,15 +996,16 @@ class TKqpTableWriteActor : public TActorBootstrapped<TKqpTableWriteActor> {
996996
997997 Schedule (reattachState.ReattachInfo .Delay , new TEvPrivate::TEvReattachToShard (ev->Get ()->TabletId ));
998998 } else {
999- TxManager->SetError (ev->Get ()->TabletId );
1000999 if (TxManager->GetState (ev->Get ()->TabletId ) == IKqpTransactionManager::EXECUTING) {
1000+ TxManager->SetError (ev->Get ()->TabletId );
10011001 RuntimeError (
10021002 NYql::NDqProto::StatusIds::UNDETERMINED,
10031003 NYql::TIssuesIds::KIKIMR_OPERATION_STATE_UNKNOWN,
10041004 TStringBuilder ()
10051005 << " Error writing to table `" << TableId.PathId .ToString () << " `"
10061006 << " . Transaction state unknown for tablet " << ev->Get ()->TabletId << " ." );
10071007 } else {
1008+ TxManager->SetError (ev->Get ()->TabletId );
10081009 RuntimeError (
10091010 NYql::NDqProto::StatusIds::UNAVAILABLE,
10101011 NYql::TIssuesIds::KIKIMR_TEMPORARILY_UNAVAILABLE,
You can’t perform that action at this time.
0 commit comments