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> {
996
996
997
997
Schedule (reattachState.ReattachInfo .Delay , new TEvPrivate::TEvReattachToShard (ev->Get ()->TabletId ));
998
998
} else {
999
- TxManager->SetError (ev->Get ()->TabletId );
1000
999
if (TxManager->GetState (ev->Get ()->TabletId ) == IKqpTransactionManager::EXECUTING) {
1000
+ TxManager->SetError (ev->Get ()->TabletId );
1001
1001
RuntimeError (
1002
1002
NYql::NDqProto::StatusIds::UNDETERMINED,
1003
1003
NYql::TIssuesIds::KIKIMR_OPERATION_STATE_UNKNOWN,
1004
1004
TStringBuilder ()
1005
1005
<< " Error writing to table `" << TableId.PathId .ToString () << " `"
1006
1006
<< " . Transaction state unknown for tablet " << ev->Get ()->TabletId << " ." );
1007
1007
} else {
1008
+ TxManager->SetError (ev->Get ()->TabletId );
1008
1009
RuntimeError (
1009
1010
NYql::NDqProto::StatusIds::UNAVAILABLE,
1010
1011
NYql::TIssuesIds::KIKIMR_TEMPORARILY_UNAVAILABLE,
You can’t perform that action at this time.
0 commit comments