diff options
| author | ilnaz <ilnaz@ydb.tech> | 2023-08-22 19:37:39 +0300 |
|---|---|---|
| committer | ilnaz <ilnaz@ydb.tech> | 2023-08-22 20:05:49 +0300 |
| commit | 24dd18e2743431eef40c048bb9036afb2ca11d78 (patch) | |
| tree | 697cd778eca9db29d9994abd00f4092c2cd3644a | |
| parent | f890c66bfbd61b57173603fe64e0075ec0d392cd (diff) | |
| download | ydb-24dd18e2743431eef40c048bb9036afb2ca11d78.tar.gz | |
Return OVERLOADED status on queue overflow KIKIMR-19080
| -rw-r--r-- | ydb/core/tx/datashard/datashard_ut_upload_rows.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/tx/tx_proxy/upload_rows_common_impl.h | 1 |
2 files changed, 2 insertions, 1 deletions
diff --git a/ydb/core/tx/datashard/datashard_ut_upload_rows.cpp b/ydb/core/tx/datashard/datashard_ut_upload_rows.cpp index 463556751a1..49e6af420d6 100644 --- a/ydb/core/tx/datashard/datashard_ut_upload_rows.cpp +++ b/ydb/core/tx/datashard/datashard_ut_upload_rows.cpp @@ -780,7 +780,7 @@ Y_UNIT_TEST_SUITE(TTxDataShardUploadRows) { }); DoUploadTestRows(server, sender, "/Root/table-1", Ydb::Type::UINT32, Ydb::StatusIds::SUCCESS); - DoUploadTestRows(server, sender, "/Root/table-1", Ydb::Type::UINT32, Ydb::StatusIds::GENERIC_ERROR); + DoUploadTestRows(server, sender, "/Root/table-1", Ydb::Type::UINT32, Ydb::StatusIds::OVERLOADED); } } diff --git a/ydb/core/tx/tx_proxy/upload_rows_common_impl.h b/ydb/core/tx/tx_proxy/upload_rows_common_impl.h index c0dc67ca333..98983436369 100644 --- a/ydb/core/tx/tx_proxy/upload_rows_common_impl.h +++ b/ydb/core/tx/tx_proxy/upload_rows_common_impl.h @@ -1033,6 +1033,7 @@ private: switch (shardResponse.GetStatus()) { case NKikimrTxDataShard::TError::WRONG_SHARD_STATE: + case NKikimrTxDataShard::TError::SHARD_IS_BLOCKED: ctx.Send(SchemeCache, new TEvTxProxySchemeCache::TEvInvalidateTable(GetKeyRange()->TableId, TActorId())); status = Ydb::StatusIds::OVERLOADED; break; |