Skip to content

Commit 231559c

Browse files
committed
fix
1 parent 04fe8ec commit 231559c

File tree

1 file changed

+0
-14
lines changed

1 file changed

+0
-14
lines changed

ydb/core/kqp/runtime/kqp_write_actor.cpp

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -2524,20 +2524,6 @@ class TKqpBufferWriteActor :public TActorBootstrapped<TKqpBufferWriteActor>, pub
25242524
getIssues());
25252525
return;
25262526
}
2527-
case NKikimrDataEvents::TEvWriteResult::STATUS_OUT_OF_SPACE: {
2528-
CA_LOG_W("Got OUT_OF_SPACE for tables."
2529-
<< " ShardID=" << ev->Get()->Record.GetOrigin() << ","
2530-
<< " Sink=" << this->SelfId() << "."
2531-
<< " Ignored this error."
2532-
<< getIssues().ToOneLineString());
2533-
TxManager->SetError(ev->Get()->Record.GetOrigin());
2534-
ReplyErrorAndDie(
2535-
NYql::NDqProto::StatusIds::OVERLOADED,
2536-
NYql::TIssuesIds::KIKIMR_OVERLOADED,
2537-
TStringBuilder() << "Tablet " << ev->Get()->Record.GetOrigin() << " is out of space. " << getPathes() << ".",
2538-
getIssues());
2539-
return;
2540-
}
25412527
case NKikimrDataEvents::TEvWriteResult::STATUS_OUT_OF_SPACE: {
25422528
CA_LOG_W("Got OUT_OF_SPACE for tables."
25432529
<< " ShardID=" << ev->Get()->Record.GetOrigin() << ","

0 commit comments

Comments
 (0)