Skip to content

Commit 83e87cd

Browse files
committed
Revert "KIKIMR-20842: make error non-retryable again"
This reverts commit 46ca396.
1 parent 93067e7 commit 83e87cd

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

ydb/core/kqp/executer_actor/kqp_data_executer.cpp

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1271,6 +1271,11 @@ class TKqpDataExecuter : public TKqpExecuterBase<TKqpDataExecuter, EExecType::Da
12711271
LOG_N("Shard " << msg->TabletId << " lost pipe while waiting for reply"
12721272
<< (msg->NotDelivered ? " (last message not delivered)" : ""));
12731273

1274+
if (ReadOnlyTx && msg->NotDelivered) {
1275+
CancelProposal(msg->TabletId);
1276+
return ReplyUnavailable(TStringBuilder() << "Could not deliver program to shard " << msg->TabletId);
1277+
}
1278+
12741279
return ReplyTxStateUnknown(msg->TabletId);
12751280
}
12761281

0 commit comments

Comments
 (0)